rx/helpers

A collection of functions to use with RxPHP

Maintainers

Details

github.com/RxPHP/RxHelpers

Source

Issues

Installs: 161 677

Dependents: 1

Suggesters: 0

Security: 0

Stars: 1

Watchers: 3

Forks: 0

Open Issues: 0

1.0.1 2017-09-14 01:31 UTC

Requires

MIT ade044bc8afc131b40287dc58b721526ab9277d6

  • Matt Bonneau <matt.woop@bonneau.net>
  • David Dan <davidwdan.woop@gmail.com>

reactreactiverxrx.phprxphp

This package is auto-updated.

Last update: 2024-12-06 00:49:52 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!