Test piping stream

Author: clue

tests/UnwrapReadableTest.php

@@ -6,6 +6,7 @@
 use React\EventLoop\Factory;
 use React\Promise\Timer;
 use Clue\React\Block;
+use React\Stream\BufferedSink;
 
 class UnwrapReadableTest extends TestCase
 {
@@ -186,4 +187,21 @@ public function testForwardsResumeToInputStream()
 
         $stream->resume();
     }
+
+    public function testPipingStreamWillForwardDataEvents()
+    {
+        $input = new ReadableStream();
+
+        $promise = Promise\resolve($input);
+        $stream = Stream\unwrapReadable($promise);
+
+        $output = new BufferedSink();
+        $stream->pipe($output);
+
+        $input->emit('data', array('hello'));
+        $input->emit('data', array('world'));
+        $input->close();
+
+        $output->promise()->then($this->expectCallableOnceWith('helloworld'));
+    }
 }