Fix: File descriptor not closed

This commit is contained in:
Christoph Wiechert
2019-03-01 10:59:58 +01:00
parent f509627aa1
commit 248be9256a

View File

@@ -83,12 +83,6 @@ class Store {
return resolve({ offset: info.offset, upload: info }); return resolve({ offset: info.offset, upload: info });
}); });
ws.on('error', reject); ws.on('error', reject);
// End writeStream on connection abort and wait for drain
readStream.on('close', () => {
ws.on('drain', () => {
ws.end();
});
});
}); });
readStream.pipe(uploadSize).pipe(ws); readStream.pipe(uploadSize).pipe(ws);