Move pipeTo test to piping.js tests file.

whatwg · Apr 21, 2014 · 87c43b2 · 87c43b2
1 parent 7cddcd4
commit 87c43b2
Show file tree

Hide file tree

Showing 2 changed files with 28 additions and 26 deletions.
diff --git a/reference-implementation/test/base-readable-stream.js b/reference-implementation/test/base-readable-stream.js
@@ -402,32 +402,6 @@ test('BaseReadableStream should be able to get data sequentially from an asynchr
   .catch(t.ifError.bind(t));
 });
 
-test('BaseReadableStream pipeTo should complete successfully upon asynchronous finish', function (t) {
-  // https://github.com/whatwg/streams/issues/80
-
-  t.plan(1);
-
-  var stream = sequentialBaseReadableStream(5, { async: true });
-
-  var dataWritten = [];
-  var dest = {
-    state: 'writable',
-    write: function (value) {
-      dataWritten.push(value);
-      return Promise.resolve();
-    },
-    close: function () {
-      t.deepEqual(dataWritten, [1, 2, 3, 4, 5]);
-      return Promise.resolve();
-    },
-    abort: function () {
-      t.fail('Should not call abort');
-    }
-  };
-
-  stream.pipeTo(dest);
-});
-
 test('BaseReadableStream cancellation puts the stream in a closed state (no data pulled yet)', function (t) {
   var stream = sequentialBaseReadableStream(5);
 
@@ -459,6 +433,7 @@ test('BaseReadableStream cancellation puts the stream in a closed state (no data
     t.fail('wait promise vended after the cancellation should not be rejected');
   });
 });
+
 test('BaseReadableStream cancellation puts the stream in a closed state (after waiting for data)', function (t) {
   var stream = sequentialBaseReadableStream(5);
 

diff --git a/reference-implementation/test/piping.js b/reference-implementation/test/piping.js
@@ -1,12 +1,39 @@
 'use strict';
 
 var test = require('tape');
+var Promise = require('es6-promise').Promise;
 var readableStreamToArray = require('./lib/readable-stream-to-array.js');
 var sequentialBaseReadableStream = require('./lib/sequential-brs.js');
 var passThroughTransform = require('./lib/pass-through-transform.js');
 
 require('../index.js');
 
+test('BaseReadableStream pipeTo should complete successfully upon asynchronous finish', function (t) {
+  // https://github.com/whatwg/streams/issues/80
+
+  t.plan(1);
+
+  var stream = sequentialBaseReadableStream(5, { async: true });
+
+  var dataWritten = [];
+  var dest = {
+    state: 'writable',
+    write: function (value) {
+      dataWritten.push(value);
+      return Promise.resolve();
+    },
+    close: function () {
+      t.deepEqual(dataWritten, [1, 2, 3, 4, 5]);
+      return Promise.resolve();
+    },
+    abort: function () {
+      t.fail('Should not call abort');
+    }
+  };
+
+  stream.pipeTo(dest);
+});
+
 test('Piping through a pass-through transform stream works', function (t) {
   t.plan(1);