From bd178ce2f0f508db1aef7a8ab0afec98e57d21c6 Mon Sep 17 00:00:00 2001 From: Jerry Kurian Date: Sat, 25 Jan 2020 12:36:21 -0500 Subject: [PATCH] Revert to old --- src/functions/demux.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/functions/demux.ts b/src/functions/demux.ts index 25e16bd..cd287dd 100644 --- a/src/functions/demux.ts +++ b/src/functions/demux.ts @@ -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(); });