rx / operator-extras
Extra Operators and Observables for RxPHP
2.1.1
2022-02-09 15:10 UTC
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