reactor.adapter

Class RxJava2Adapter

java.lang.Object

reactor.adapter.RxJava2Adapter

public abstract class RxJava2Adapter
extends java.lang.Object

Convert between RxJava 2 types and Mono/Flux back and forth and compose backpressure, cancellation and fusion where applicable.

Method Summary

Modifier and Type	Method and Description
static Mono<java.lang.Void>	completableToMono(io.reactivex.Completable source) Wraps a RxJava Completable into a Mono instance.
static <T> Flux<T>	flowableToFlux(io.reactivex.Flowable<T> source) Wraps a Flowable instance into a Flux instance, composing the micro-fusion properties of the Flowable through.
static <T> io.reactivex.Flowable<T>	fluxToFlowable(Flux<T> source) Wraps a Flux instance into a Flowable instance, composing the micro-fusion properties of the Flux through.
static <T> io.reactivex.Observable<T>	fluxToObservable(Flux<T> source) Wraps a Flux instance into a RxJava Observable.
static io.reactivex.Completable	monoToCompletable(Mono<?> source) Wraps a void-Mono instance into a RxJava Completable.
static <T> io.reactivex.Flowable<T>	monoToFlowable(Mono<T> source) Wraps a Mono instance into a Flowable instance, composing the micro-fusion properties of the Flux through.
static <T> io.reactivex.Single<T>	monoToSingle(Mono<T> source) Wraps a Mono instance into a RxJava Single.
static <T> Flux<T>	observableToFlux(io.reactivex.Observable<T> source, io.reactivex.BackpressureStrategy strategy) Wraps an RxJava Observable and applies the given backpressure trategy.
static <T> Mono<T>	singleToMono(io.reactivex.Single<T> source) Wraps a RxJava Single into a Mono instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

flowableToFlux

public static <T> Flux<T> flowableToFlux(io.reactivex.Flowable<T> source)

Wraps a Flowable instance into a Flux instance, composing the micro-fusion properties of the Flowable through.

Type Parameters:

T - the value type

Parameters:

source - the source flowable

Returns:

the new Flux instance

fluxToFlowable

public static <T> io.reactivex.Flowable<T> fluxToFlowable(Flux<T> source)

Wraps a Flux instance into a Flowable instance, composing the micro-fusion properties of the Flux through.

Type Parameters:

T - the value type

Parameters:

source - the source flux

Returns:

the new Flux instance

monoToFlowable

public static <T> io.reactivex.Flowable<T> monoToFlowable(Mono<T> source)

Wraps a Mono instance into a Flowable instance, composing the micro-fusion properties of the Flux through.

Type Parameters:

T - the value type

Parameters:

source - the source flux

Returns:

the new Flux instance

monoToCompletable

public static io.reactivex.Completable monoToCompletable(Mono<?> source)

Wraps a void-Mono instance into a RxJava Completable.

Parameters:

source - the source Mono instance

Returns:

the new Completable instance

completableToMono

public static Mono<java.lang.Void> completableToMono(io.reactivex.Completable source)

Wraps a RxJava Completable into a Mono instance.

Parameters:

source - the source Completable

Returns:

the new Mono instance

monoToSingle

public static <T> io.reactivex.Single<T> monoToSingle(Mono<T> source)

Wraps a Mono instance into a RxJava Single.

If the Mono is empty, the single will signal a NoSuchElementException.

Type Parameters:

T - the value type

Parameters:

source - the source Mono instance

Returns:

the new Single instance

singleToMono

public static <T> Mono<T> singleToMono(io.reactivex.Single<T> source)

Wraps a RxJava Single into a Mono instance.

Type Parameters:

T - the value type

Parameters:

source - the source Single

Returns:

the new Mono instance

observableToFlux

public static <T> Flux<T> observableToFlux(io.reactivex.Observable<T> source,
                                           io.reactivex.BackpressureStrategy strategy)

Wraps an RxJava Observable and applies the given backpressure trategy.

Type Parameters:

T - the value type

Parameters:

source - the source Observable

strategy - the backpressure strategy (BUFFER, DROP, LATEST)

Returns:

the new Flux instance

fluxToObservable

public static <T> io.reactivex.Observable<T> fluxToObservable(Flux<T> source)

Wraps a Flux instance into a RxJava Observable.

Type Parameters:

T - the value type

Parameters:

source - the source Flux

Returns:

the new Observable instance