ldiamond/strom
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Revert to old

Browse Source
This commit is contained in:
Jerry Kurian 2020-01-25 12:36:21 -05:00
parent 1227ce7095
commit bd178ce2f0
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/functions/demux.ts
View File

@ -60,8 +60,8 @@ class Demux extends Writable {
(this.streamsByKey[destKey] as any).pipe(this.destination);
}
}
const writeRes = this.streamsByKey[destKey].write(chunk, encoding);
if (!writeRes) {
if (!this.streamsByKey[destKey].write(chunk, encoding)) {
this.streamsByKey[destKey].once("drain", () => {
cb();
});