Terminate streams with an empty record

Author: fbbdev

lib/streams.js

@@ -68,6 +68,12 @@ function OutputStream(conn, id, recordType) {
     this._id = id;
 
     this._open = true;
+
+    this.on('finish', function () {
+        this._conn.stream.writeRecord(
+            this._id,
+            new this.recordType());
+    });
 }
 util.inherits(OutputStream, stream.Writable);
 
@@ -147,6 +153,12 @@ function IOStream(conn, id, recordType) {
     this._id = id;
 
     this._open = true;
+
+    this.on('finish', function () {
+        this._conn.stream.writeRecord(
+            this._id,
+            new this.recordType());
+    });
 }
 util.inherits(IOStream, stream.Duplex);