reactor-core-js
The Reactive-Streams based implementation of Reactor-Core.
Importing
npm install reactor-core-js
Usage
import { Flux } from './node_modules/reactor-core-js/flux';
Flux.range(1, 10)
.take(5)
.map(v => v * 2)
.flatMap(v => Flux.range(v, 2))
.subscribe(v => console.log(v));
Reactive Entry points
Flux
ambcombineLatest,combineLatest2,combineLatest3,combineLatest4concatconcatArraydeferemptyfromArrayfromCallableintervaljustmergemergeArrayneverrangeswitchOnNexttimerusingzip,zip2,zip3,zip4
Mono
- TBD
Reactive stay
Flux
ascollectcombineWithcomposeconcatWithdebouncedoOnAfterNextdoOnAfterTerminateddoOnCanceldoOnCompletedoOnErrordoOnNextdoOnSubscribefilterflatMapgeneratehideliftmaponErrorReturnonErrorResumeNextreducesampleskipskipLastskipUntilswitchMaptaketakeLasttakeUntilthrottleFirsttoArraywithLatestFromzipWith
Mono
- TBD
Reactive Leave
Flux
subscribe
Mono
subscribe
Scheduler
Import scheduler package.
DefaultScheduler.INSTANCE