Pass timeout to end()

icicleio · Dec 11, 2015 · 9ef7200 · 9ef7200
1 parent ec32a1f
commit 9ef7200
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/functions.php b/src/functions.php
@@ -85,7 +85,7 @@ function pipe(
         );
 
         if ($end && $destination->isWritable()) {
-            yield $destination->end();
+            yield $destination->end('', $timeout);
         }
 
         yield $bytes;

diff --git a/tests/FunctionsTest.php b/tests/FunctionsTest.php
@@ -131,7 +131,7 @@ public function testPipeEndOnUnexpectedClose()
         };
         $stream->write(self::WRITE_STRING, 0)->willReturn($generator());
 
-        $stream->end()->shouldBeCalled();
+        $stream->end('', 0)->shouldBeCalled();
 
         $promise = new Coroutine(Stream\pipe($readable, $stream->reveal(), true));
 
@@ -528,7 +528,7 @@ public function testPipeToEndOnUnexpectedClose()
         };
         $stream->write(self::WRITE_STRING, 0)->willReturn($generator());
 
-        $stream->end()->shouldBeCalled();
+        $stream->end('', 0)->shouldBeCalled();
 
         $promise = new Coroutine(Stream\pipe($readable, $stream->reveal(), true, 0, '!'));