rx / helpers
与 RxPHP 一起使用的一系列函数的集合
1.0.1
2017-09-14 01:31 UTC
Requires
- reactivex/rxphp: ^2.0
This package is auto-updated.
Last update: 2024-09-06 00:10:19 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!