Skip to content

Commit 45df9ac

Browse files
committed
Introduce convenience factory method for BufferedSink
This makes the API way more usable: BufferedSink::createPromise($readable) ->then($callback);
1 parent afbb4c7 commit 45df9ac

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

BufferedSink.php

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,4 +49,12 @@ public function promise()
4949
{
5050
return $this->deferred->promise();
5151
}
52+
53+
public static function createPromise(ReadableStream $stream)
54+
{
55+
$sink = new static();
56+
$stream->pipe($sink);
57+
58+
return $sink->promise();
59+
}
5260
}

0 commit comments

Comments
 (0)