RxPHP alternatives and similar libraries
Based on the "Event" category.
Alternatively, view RxPHP alternatives based on common mentions on social networks and blogs.
-
-
AdapterMan
Run almost any PHP app faster and asynchronously with Workerman, without touch 1 line of code in your fw or app. Also use it as Serverless.
Do you think we are missing an alternative of RxPHP or a related project?
README
RxPHP
Reactive extensions for PHP. The reactive extensions for PHP are a set of libraries to compose asynchronous and event-based programs using observable collections and LINQ-style query operators in PHP.
note: This repo is for v2.x, the latest version of RxPHP, not v1.x.
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
Have fun running the demos in /demo.
note: When running the demos, the scheduler is automatically bootstrapped. When using RxPHP within your own project, you'll need to set the default scheduler.
Installation
- Install an event loop. Any event loop should work, but the ReactPHP event loop is recommended.
$ composer require react/event-loop
- Install RxPHP using composer.
$ composer require reactivex/rxphp
- Write some code.
<?php
require_once __DIR__ . '/vendor/autoload.php';
use Rx\Observable;
use React\EventLoop\Factory;
use Rx\Scheduler;
$loop = Factory::create();
//You only need to set the default scheduler once
Scheduler::setDefaultFactory(function() use($loop){
return new Scheduler\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
Some async PHP frameworks have yet to fully embrace the awesome power of observables. To help ease the transition, RxPHP has built in support for ReactPHP promises.
Mixing a promise into an observable stream:
Observable::interval(1000)
->flatMap(function ($i) {
return Observable::fromPromise(\React\Promise\resolve(42 + $i));
})
->subscribe(function ($v) {
echo $v . PHP_EOL;
});
Converting an Observable into a promise. (This is useful for libraries that use generators and coroutines):
$observable = Observable::interval(1000)
->take(10)
->toArray()
->map('json_encode');
$promise = $observable->toPromise();
Additional Information
License
RxPHP is licensed under the MIT License - see the LICENSE file for details
*Note that all licence references and agreements mentioned in the RxPHP README section above
are relevant to that project's source code only.