Example

$source = \Rx\Observable::fromArray([1,2,3,4]);$source->subscribe(function ($x) {echo'Next:',$x,PHP_EOL;    },function (Exception$ex) {echo'Error:',$ex->getMessage(),PHP_EOL;    },function () {echo'Completed',PHP_EOL;    });//Next: 1//Next: 2//Next: 3//Next: 4//Completed

Try out the demos

$ git clone https://github.com/ReactiveX/RxPHP.git$cd RxPHP$ composer install$ php demo/interval/interval.php

Installation

$ composer require react/event-loop

$ composer require reactivex/rxphp

<?phprequire_once__DIR__ .'/vendor/autoload.php';useRx\Observable;useReact\EventLoop\Factory;useRx\Scheduler;$loop = Factory::create();//You only need to set the default scheduler onceScheduler::setDefaultFactory(function()use($loop){returnnewScheduler\EventLoopScheduler($loop);});Observable::interval(1000)    ->take(5)    ->flatMap(function ($i) {return Observable::of($i +1);    })    ->subscribe(function ($e) {echo$e,PHP_EOL;    });$loop->run();

Working with Promises

Observable::interval(1000)    ->flatMap(function ($i) {return Observable::fromPromise(\React\Promise\resolve(42 +$i));    })    ->subscribe(function ($v) {echo$v .PHP_EOL;    });

$observable = Observable::interval(1000)    ->take(10)    ->toArray()    ->map('json_encode');$promise =$observable->toPromise();

Additional Information

License