Interface

The subscription point of a publisher: each call to subscribe() makes a reader that receives every later message.

Introduction#

Iterating over it reads the messages of a new subscription.

Class synopsis#

interface SubscribersInterface extends \IteratorAggregate, \Traversable {
    /* Methods */
    public SubscribersInterface::subscribe(): SubscriberInterface
}

Methods#

Examples#

phasync::run(function () {
    phasync::publisher($subscribers, $publisher);

    $subscription = $subscribers->subscribe();
    $publisher->write('first');
    $publisher->close();

    echo $subscription->read();   // first
});

See also#