From caa853bb06c9ef1ba4203a42ad9e1072c3988a38 Mon Sep 17 00:00:00 2001
From: isaacs <i@izs.me>
Date: Thu, 4 Oct 2012 16:58:43 -0700
Subject: [PATCH] transform: Automatically read() on _write when read buffer is
 empty

---
 lib/_stream_transform.js | 16 +++++++++++++++-
 1 file changed, 15 insertions(+), 1 deletion(-)

diff --git a/lib/_stream_transform.js b/lib/_stream_transform.js
index a3603f42a6..40917de7ab 100644
--- a/lib/_stream_transform.js
+++ b/lib/_stream_transform.js
@@ -110,14 +110,28 @@ Transform.prototype._transform = function(chunk, output, cb) {
 
 Transform.prototype._write = function(chunk, cb) {
   var ts = this._transformState;
+  var rs = this._readableState;
   ts.buffer.push([chunk, cb]);
 
+  // no need for auto-pull if already in the midst of one.
+  if (ts.transforming)
+    return;
+
   // now we have something to transform, if we were waiting for it.
-  if (ts.pendingReadCb && !ts.transforming) {
+  // kick off a _read to pull it in.
+  if (ts.pendingReadCb) {
     var readcb = ts.pendingReadCb;
     ts.pendingReadCb = null;
     this._read(-1, readcb);
   }
+
+  // if we weren't waiting for it, but nothing is queued up, then
+  // still kick off a transform, just so it's there when the user asks.
+  if (rs.length === 0) {
+    var ret = this.read();
+    if (ret !== null)
+      return cb(new Error('invalid stream transform state'));
+  }
 };
 
 Transform.prototype._read = function(n, readcb) {