rx / operator-extras
Extra Operators and Observables for RxPHP
Installs: 185 280
Dependents: 7
Suggesters: 0
Security: 0
Stars: 1
Watchers: 3
Forks: 0
Open Issues: 0
Requires
- php: >=7.0
- reactivex/rxphp: ^2.0
Requires (Dev)
- phpunit/phpunit: ^5.5
README
This library houses extra operators that are not part of the official RxPHP library.
Operators
cut
- splits a stream with a delimiterrepeatDelay
- repeats an observable sequence with when it completes after a delay
$observable->repeatDelay($initialDelay, $maxRetries, $maxRetryDelay, $retryDelayGrowth);
retryDelay
- retries an observable sequence when it errors after a delay
$observable->retryDelay($initialDelay, $maxRetries, $maxRetryDelay, $retryDelayGrowth);
Observables
FromEventEmitterObservable
- converts event emitters like react streams to RxPHP Observables