fix IO await

This commit is contained in:
Trym Lund Flogard 2021-06-05 13:47:27 +02:00
parent 40bfed39fc
commit d363b4a3d0
3 changed files with 8 additions and 2 deletions

3
dist/index.js vendored
View File

@ -610,12 +610,15 @@ class NextcloudClient {
headers: { 'Content-Length': fileStat.size.toString() }
});
fileStream.pipe(remoteStream);
// see: https://github.com/nodejs/node/issues/22088
const timer = setTimeout(() => { }, 20000);
await new Promise((resolve, reject) => {
fileStream.on('error', e => reject(e)).on('close', () => resolve());
});
await new Promise((resolve, reject) => {
remoteStream.on('error', e => reject(e)).on('close', () => resolve());
});
clearTimeout(timer);
return remoteFilePath;
}
async shareFile(remoteFilePath) {

2
dist/index.js.map vendored

File diff suppressed because one or more lines are too long

View File

@ -168,14 +168,17 @@ export class NextcloudClient {
fileStream.pipe(remoteStream)
// see: https://github.com/nodejs/node/issues/22088
const timer = setTimeout(() => {}, 20_000);
await new Promise<void>((resolve, reject) => {
fileStream.on('error', e => reject(e)).on('close', () => resolve())
})
await new Promise<void>((resolve, reject) => {
remoteStream.on('error', e => reject(e)).on('close', () => resolve())
})
clearTimeout(timer);
return remoteFilePath
}