rx/helpers

A collection of functions to use with RxPHP

1.0.1 2017-09-14 01:31 UTC

Requires

• reactivex/rxphp: ^2.0

MIT

• Matt Bonneau
• David Dan

• react
• reactive
• rx
• rx.php
• rxphp

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!