reactor-core-js

WebJar for reactor-core-js

License	Apache-2.0
Categories	JavaScript Languages React User Interface Web Frameworks Reactor Container Microservices Reactive libraries
GroupId	org.webjars.npm
ArtifactId	reactor-core-js
Last Version	0.5.0
Release Date	Feb 8, 2018
Type	jar
Description	reactor-core-js WebJar for reactor-core-js
Project URL	http://webjars.org
Source Code Management	https://github.com/reactor/reactor-core-js

Download reactor-core-js

Filename	Size
reactor-core-js-0.5.0.pom
reactor-core-js-0.5.0.jar	196 KB
reactor-core-js-0.5.0-sources.jar	22 bytes
reactor-core-js-0.5.0-javadoc.jar	22 bytes

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/org.webjars.npm/reactor-core-js/ -->
<dependency>
    <groupId>org.webjars.npm</groupId>
    <artifactId>reactor-core-js</artifactId>
    <version>0.5.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/org.webjars.npm/reactor-core-js/
implementation 'org.webjars.npm:reactor-core-js:0.5.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/org.webjars.npm/reactor-core-js/
implementation ("org.webjars.npm:reactor-core-js:0.5.0")

Apache Buildr

'org.webjars.npm:reactor-core-js:jar:0.5.0'

Apache Ivy

<dependency org="org.webjars.npm" name="reactor-core-js" rev="0.5.0">
  <artifact name="reactor-core-js" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='org.webjars.npm', module='reactor-core-js', version='0.5.0')
)

Scala SBT

libraryDependencies += "org.webjars.npm" % "reactor-core-js" % "0.5.0"

Leiningen

[org.webjars.npm/reactor-core-js "0.5.0"]

Dependencies

There are no dependencies for this project. It is a standalone project that does not depend on any other jars.

Project Modules

There are no modules declared in this project.

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

Reactor

Reactive Streams based projects for backpressure-ready asynchronous message passing.

Versions

Version
0.5.0 Feb 8, 2018