phasync\Internal\Subscriber final class

Documentation

This class is created via phasync::publisher()

Inheritance

Implements: phasync\SubscriberInterface IteratorAggregate phasync\SelectableInterface Traversable phasync\ReadChannelInterface

Properties (4)

private int $id
private ?phasync\Internal\Subscribers $publisher
private ?phasync\Internal\ChannelMessage $currentMessage
private bool $closed

Methods (10)

public __construct()

Documentation missing

public activate()

Documentation missing

public await()

Wait for data without reading

public isReady()

Documentation missing

public getIterator()

Documentation missing

public __destruct()

Documentation missing

public close()

Documentation missing

public isClosed()

Documentation missing

public read()

Documentation missing

public isReadable()

Documentation missing

Source

src/Internal/Subscriber.php:14-104