The Reactive-Streams based implementation of Reactor-Core.
npm install reactor-core-js
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));
amb
combineLatest
,combineLatest2
,combineLatest3
,combineLatest4
concat
concatArray
defer
empty
fromArray
fromCallable
interval
just
merge
mergeArray
never
range
switchOnNext
timer
using
zip
,zip2
,zip3
,zip4
- TBD
as
collect
combineWith
compose
concatWith
debounce
doOnAfterNext
doOnAfterTerminated
doOnCancel
doOnComplete
doOnError
doOnNext
doOnSubscribe
filter
flatMap
generate
hide
lift
map
onErrorReturn
onErrorResumeNext
reduce
sample
skip
skipLast
skipUntil
switchMap
take
takeLast
takeUntil
throttleFirst
toArray
withLatestFrom
zipWith
- TBD
subscribe
subscribe
Import scheduler
package.
DefaultScheduler.INSTANCE