WIP 6

overlookmotel · Sep 22, 2019 · d9fbab1 · d9fbab1
1 parent fef31d7
commit d9fbab1
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/lib/index.js b/lib/index.js
@@ -229,6 +229,13 @@ class ChopStream extends Writable {
 			chunk = buffers[index];
 			chunkEnd = chunkStart + chunk.length;
 		}
+
+		// Call `._write()`'s callback if have streamed out all received
+		const cb = this._writeCb;
+		if (cb && chunkEnd === this._position) {
+			this._writeCb(null);
+			this._writeCb = null;
+		}
 	}
 
 	/**