if 0 len callback

mcfedr · Aug 8, 2012 · e7c0e88 · e7c0e88
1 parent 6e9d85f
commit e7c0e88
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/pullstream.js b/pullstream.js
@@ -47,6 +47,10 @@ PullStream.prototype.pull = over([
 ]);
 
 PullStream.prototype._pull = function (len, callback) {
+  if (len === 0) {
+    return callback(null, new Buffer(0));
+  }
+
   var self = this;
   var lenLeft = len;
   var resultBuffer = new streamBuffers.WritableStreamBuffer({
@@ -89,6 +93,10 @@ PullStream.prototype.pipe = over([
 ]);
 
 PullStream.prototype._pipe = function (len, destStream) {
+  if (len === 0) {
+    return callback(null, new Buffer(0));
+  }
+
   var self = this;
   this._emitter.on('data', dataOrEnd.bind(this, 'data'));
   this._emitter.on('end', dataOrEnd.bind(this, 'end'));

diff --git a/test/pullStreamTest.js b/test/pullStreamTest.js
@@ -127,7 +127,6 @@ test("read from file", function (t) {
 
   var ps = new PullStream();
   ps.on('end', function () {
-    sourceStream.destroy();
     t.end();
   });