Skip to content
This repository has been archived by the owner. It is now read-only.
master
Go to file
Code

Latest commit

 

Git stats

Files

Permalink
Failed to load latest commit information.
Type
Name
Latest commit message
Commit time
 
 
src
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

README.md

Join the chat at https://gitter.im/reactor/reactor NPM version

Travis CI

reactor-core-js

The Reactive-Streams based implementation of Reactor-Core.

Importing

npm install reactor-core-js

NPM

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

  • amb
  • combineLatest, combineLatest2, combineLatest3, combineLatest4
  • concat
  • concatArray
  • defer
  • empty
  • fromArray
  • fromCallable
  • interval
  • just
  • merge
  • mergeArray
  • never
  • range
  • switchOnNext
  • timer
  • using
  • zip, zip2, zip3, zip4

Mono

  • TBD

Reactive stay

Flux

  • 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

Mono

  • TBD

Reactive Leave

Flux

  • subscribe

Mono

  • subscribe

Scheduler

Import scheduler package.

  • DefaultScheduler.INSTANCE

About

The Reactive-Streams based implementation of Reactor-Core in Javascript

Resources

License

You can’t perform that action at this time.