-
-
Notifications
You must be signed in to change notification settings - Fork 249
/
Stream.php
21 lines (19 loc) 路 858 Bytes
/
Stream.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
<?php
namespace Amp;
/**
* Represents a set of asynchronous values. A stream is analogous to an asynchronous generator, yielding (emitting)
* values when they are available, returning a value (success value) when the stream completes or throwing an
* exception (failure reason).
*/
interface Stream extends Promise {
/**
* Registers a callback to be invoked each time value is emitted from the stream. If the function returns an
* promise, back-pressure is applied to the promise until the returned promise is resolved.
*
* Exceptions thrown from $onNext (or failures of promises returned from $onNext) will fail the returned
* Subscriber with the thrown exception.
*
* @param callable $onNext Function invoked each time a value is emitted from the stream.
*/
public function listen(callable $onNext);
}