rx / helpers
A collection of functions to use with RxPHP
Installs: 161 546
Dependents: 1
Suggesters: 0
Security: 0
Stars: 1
Watchers: 3
Forks: 0
Open Issues: 0
Requires
- reactivex/rxphp: ^2.0
This package is auto-updated.
Last update: 2024-11-06 00:37:37 UTC
README
Observable::of(Observable::fromArray([1, 2, 3, 4, 5])) ->filter(\Rx\is(Observable::class)) ->mergeAll() ->filter(\Rx\notEqualTo(2)) ->filter('rx\even') ->reduce('rx\add') ->map(\Rx\p('rx\mult', 3)) ->map(\Rx\p('rx\sub', 2)) ->map(\Rx\p('rx\concatLeft', 'total: ')) ->compose(\Rx\echoFinally('Test ')) ->subscribe(\Rx\echoObserver('Test ')); //Test Next value: total: 10 //Test Complete! //Test Finally!