Name: RxPHP
Owner: ReactiveX
Description: Reactive extensions for PHP
Created: 2016-01-23 20:44:18.0
Updated: 2018-05-23 14:54:32.0
Pushed: 2018-05-01 10:09:55.0
Homepage: null
Size: 958
Language: PHP
GitHub Committers
| User | Most Recent Commit | # Commits |
|---|
Other Committers
| User | Most Recent Commit | # Commits |
|---|
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.
rce = \Rx\Observable::fromArray([1, 2, 3, 4]);
rce->subscribe(
function ($x) {
echo 'Next: ', $x, PHP_EOL;
},
function (Exception $ex) {
echo 'Error: ', $ex->getMessage(), PHP_EOL;
},
function () {
echo 'Completed', PHP_EOL;
}
xt: 1
xt: 2
xt: 3
xt: 4
mpleted
t clone https://github.com/ReactiveX/RxPHP.git
RxPHP
mposer install
p 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.
mposer require react/event-loop
mposer require reactivex/rxphp
p
ire_once __DIR__ . '/vendor/autoload.php';
Rx\Observable;
React\EventLoop\Factory;
Rx\Scheduler;
p = Factory::create();
u only need to set the default scheduler once
duler::setDefaultFactory(function() use($loop){
return new Scheduler\EventLoopScheduler($loop);
rvable::interval(1000)
->take(5)
->flatMap(function ($i) {
return Observable::of($i + 1);
})
->subscribe(function ($e) {
echo $e, PHP_EOL;
});
p->run();
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:
rvable::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):
ervable = Observable::interval(1000)
->take(10)
->toArray()
->map('json_encode');
mise = $observable->toPromise();
RxPHP is licensed under the MIT License - see the LICENSE file for details