function AbstractDriver::onReadable

Overrides Driver::onReadable

File

vendor/revolt/event-loop/src/EventLoop/Internal/AbstractDriver.php, line 175

Class

AbstractDriver

Event loop driver which implements all basic operations to allow interoperability.

Namespace

Revolt\EventLoop\Internal

Code

public function onReadable(mixed $stream, \Closure $closure) : string {
    $streamCallback = new StreamReadableCallback($this->nextId++, $closure, $stream);
    $this->callbacks[$streamCallback->id] = $streamCallback;
    $this->enableQueue[$streamCallback->id] = $streamCallback;
    return $streamCallback->id;
}