Add duplex stream

Author: fbbdev

lib/streams.js

@@ -110,3 +110,29 @@ OutputStream.prototype._write = function (chunk, encoding, callback) {
         new this.type(chunks.shift()),
         callback.bind(this));
 };
+
+/**
+ * function IOStream([buffer])
+ * Duplex stream interface for FastCGI input streams
+ */
+
+function IOStream(conn, id, recordType) {
+    stream.Duplex.call(this);
+
+    this.recordType = recordType || fcgi.records.StdOut;
+
+    this._buffer = [];
+    this._canPush = true;
+
+    this._conn = conn;
+    this._id = id;
+
+    this._open = true;
+}
+util.inherits(IOStream, stream.Duplex);
+
+IOStream.prototype._data = InputStream.prototype._data;
+IOStream.prototype._read = InputStream.prototype._read;
+
+IOStream.prototype.close = OutputStream.prototype.close;
+IOStream.prototype._write = OutputStream.prototype._write;