check pause status before resuming

tape-testing · May 4, 2013 · 606b141 · 606b141
1 parent bd9e9a6
commit 606b141
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/index.js b/index.js
@@ -81,7 +81,14 @@ function createHarness (conf_) {
 
     test.createStream = function () {
         if (!results) results = createResultStream();
-        nextTick(function () { results.resume() });
+
+        var _pause = results.pause;
+        var paused = false;
+        results.pause = function () { paused = true };
+
+        nextTick(function () {
+            if (!paused) results.resume();
+        });
         return results;
     };
 

diff --git a/lib/results.js b/lib/results.js
@@ -115,7 +115,7 @@ Results.prototype.push = function (t, parentT) {
 
 Results.prototype.close = function () {
     var self = this;
-if (self.closed) self.stream.emit('error', new Error('ALREADY CLOSED'));
+    if (self.closed) self.stream.emit('error', new Error('ALREADY CLOSED'));
     self.closed = true;
     var write = function (s) { self.stream.queue(s) };