Mastering PHP 7

Observables and event loop 

Let's go ahead and see how we can make our observables work with an event loop:

<?phprequire_once __DIR__ . '/vendor/autoload.php';use \React\EventLoop\Factory;use \Rx\Scheduler;use \Rx\Observable;use \Rx\Subject\Subject;use \Rx\Scheduler\EventLoopScheduler;$loop = Factory::create();Scheduler::setDefaultFactory(function () use ($loop) {    return new Scheduler\EventLoopScheduler($loop);});$stdin = fopen('php://stdin', 'r');stream_set_blocking($stdin, 0);$observer = new class() extends Subject{    public function onCompleted()    {        echo '$observer.onCompleted: ', PHP_EOL;        parent::onCompleted();    }    public function onNext($val)    {        echo '$observer.onNext: ', $val, PHP_EOL;        parent::onNext($val);    }    public function onError(\Throwable ...