Fix writable stream implementation

Author: fbbdev

lib/streams.js

@@ -92,30 +92,23 @@ OutputStream.prototype._write = function (chunk, encoding, callback) {
         chunk = new Buffer(chunk, encoding);
     }
 
-    if (chunk.length === 0) {
+    if (chunk.length <= 0) {
         callback.call(this);
         return;
     }
 
-    if (chunk.length <= 65535) {
-        chunks.push(chunk);
-    } else {
-        var splits = Math.floor(chunk.length / 65535);
-        var start = 0;
-        for (var i = 0; i < splits; ++i) {
-            chunks.push(chunk.slice(start, start += 65535));
-        }
-        chunks.push(chunk.slice(start, chunk.length));
-    }
-
-    while (chunks.length > 1) {
+    var start = 0, end = 65535;
+    while (end < chunk.length) {
         this._conn.stream.writeRecord(
-            this._id, new this.recordType(chunks.shift()));
+            this._id, new this.recordType(chunk.slice(start, end)));
+
+        start = end;
+        end += 65535;
     }
 
     this._conn.stream.writeRecord(
         this._id,
-        new this.recordType(chunks.shift()),
+        new this.recordType(chunk.slice(start)),
         callback.bind(this));
 };