reactor.adapter.rxjava

Class RxJava3Adapter

java.lang.Object

reactor.adapter.rxjava.RxJava3Adapter

public abstract class RxJava3Adapter
extends Object

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

Method Summary

Modifier and Type	Method and Description
static reactor.core.publisher.Mono<Void>	completableToMono(io.reactivex.rxjava3.core.Completable source) Adapt an Rxjava3 Completable into a Mono<Void> instance.
static <T> reactor.core.publisher.Flux<T>	flowableToFlux(io.reactivex.rxjava3.core.Flowable<T> source) Adapt an Rxjava3 Flowable instance into a Flux instance, allowing micro-fusion and backpressure propagation to occur between the two libraries.
static <T> io.reactivex.rxjava3.core.Flowable<T>	fluxToFlowable(reactor.core.publisher.Flux<T> source) Adapt a Flux instance into an Rxjava3 Flowable instance, allowing micro-fusion and backpressure propagation to occur between the two libraries.
static <T> io.reactivex.rxjava3.core.Observable<T>	fluxToObservable(reactor.core.publisher.Flux<T> source) Adapt a Flux instance into an Rxjava3 Observable.
static <T> reactor.core.publisher.Mono<T>	maybeToMono(io.reactivex.rxjava3.core.Maybe<T> source) Adapt an RxJava 3 Maybe into a Mono instance.
static io.reactivex.rxjava3.core.Completable	monoToCompletable(reactor.core.publisher.Mono<?> source) Adapt a Mono instance into an Rxjava3 Completable instance.
static <T> io.reactivex.rxjava3.core.Completable	monoToCompletable(reactor.core.publisher.Mono<T> source, Consumer<T> discardHandler) Adapt a Mono instance into an Rxjava3 Completable instance, discarding potential mono value through the provided Consumer (to be used in a similar fashion to Mono.doOnDiscard(Class, Consumer) hook).
static <T> io.reactivex.rxjava3.core.Flowable<T>	monoToFlowable(reactor.core.publisher.Mono<T> source) Adapt a Mono instance into an Rxjava3 Flowable instance, allowing micro-fusion and backpressure propagation to occur between the two libraries.
static <T> io.reactivex.rxjava3.core.Maybe<T>	monoToMaybe(reactor.core.publisher.Mono<T> source) Adapt a Mono instance into an RxJava 3 Maybe.
static <T> io.reactivex.rxjava3.core.Single<T>	monoToSingle(reactor.core.publisher.Mono<T> source) Adapt a Mono instance into an Rxjava3 Single.
static <T> reactor.core.publisher.Flux<T>	observableToFlux(io.reactivex.rxjava3.core.Observable<T> source, io.reactivex.rxjava3.core.BackpressureStrategy strategy) Adapt an RxJava 3 Observable into a Flux and let that flux deal with backpressure by first turning it into a Flowable with the given RxJava3 BackpressureStrategy.
static <T> reactor.core.publisher.Mono<T>	singleToMono(io.reactivex.rxjava3.core.Single<T> source) Adapt an Rxjava3 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> reactor.core.publisher.Flux<T> flowableToFlux(io.reactivex.rxjava3.core.Flowable<T> source)

Adapt an Rxjava3 Flowable instance into a Flux instance, allowing micro-fusion and backpressure propagation to occur between the two libraries.

Type Parameters:

T - the value type

Parameters:

source - the source Flowable

Returns:

the new Flux instance

fluxToFlowable

public static <T> io.reactivex.rxjava3.core.Flowable<T> fluxToFlowable(reactor.core.publisher.Flux<T> source)

Adapt a Flux instance into an Rxjava3 Flowable instance, allowing micro-fusion and backpressure propagation to occur between the two libraries.

Type Parameters:

T - the value type

Parameters:

source - the source Flux

Returns:

the new Flowable instance

monoToFlowable

public static <T> io.reactivex.rxjava3.core.Flowable<T> monoToFlowable(reactor.core.publisher.Mono<T> source)

Adapt a Mono instance into an Rxjava3 Flowable instance, allowing micro-fusion and backpressure propagation to occur between the two libraries.

Type Parameters:

T - the value type

Parameters:

source - the source Mono

Returns:

the new Flowable instance

monoToCompletable

public static io.reactivex.rxjava3.core.Completable monoToCompletable(reactor.core.publisher.Mono<?> source)

Adapt a Mono instance into an Rxjava3 Completable instance.

Unlike the monoToCompletable(Mono, Consumer) variant, this one doesn't perform any specific discarding of the emitted value (if there is one).

Parameters:

source - the source Mono, which value to ignore

Returns:

the new Completable instance

See Also:

Mono.ignoreElement(), monoToCompletable(Mono, Consumer)

monoToCompletable

public static <T> io.reactivex.rxjava3.core.Completable monoToCompletable(reactor.core.publisher.Mono<T> source,
                                                                          Consumer<T> discardHandler)

Adapt a Mono instance into an Rxjava3 Completable instance, discarding potential mono value through the provided Consumer (to be used in a similar fashion to Mono.doOnDiscard(Class, Consumer) hook). The consumer MUST complete normally, without throwing any exceptions.

Parameters:

source - the source Mono, which value to ignore and discard

Returns:

the new Completable instance

See Also:

Mono.ignoreElement(), monoToCompletable(Mono)

completableToMono

public static reactor.core.publisher.Mono<Void> completableToMono(io.reactivex.rxjava3.core.Completable source)

Adapt an Rxjava3 Completable into a Mono<Void> instance.

Parameters:

source - the source Completable

Returns:

the new Mono instance

monoToSingle

public static <T> io.reactivex.rxjava3.core.Single<T> monoToSingle(reactor.core.publisher.Mono<T> source)

Adapt a Mono instance into an Rxjava3 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> reactor.core.publisher.Mono<T> singleToMono(io.reactivex.rxjava3.core.Single<T> source)

Adapt an Rxjava3 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> reactor.core.publisher.Flux<T> observableToFlux(io.reactivex.rxjava3.core.Observable<T> source,
                                                                  io.reactivex.rxjava3.core.BackpressureStrategy strategy)

Adapt an RxJava 3 Observable into a Flux and let that flux deal with backpressure by first turning it into a Flowable with the given RxJava3 BackpressureStrategy.

Type Parameters:

T - the value type

Parameters:

source - the source Observable

strategy - the BackpressureStrategy

Returns:

the new Flux instance

fluxToObservable

public static <T> io.reactivex.rxjava3.core.Observable<T> fluxToObservable(reactor.core.publisher.Flux<T> source)

Adapt a Flux instance into an Rxjava3 Observable.

Type Parameters:

T - the value type

Parameters:

source - the source Flux

Returns:

the new Observable instance

maybeToMono

public static <T> reactor.core.publisher.Mono<T> maybeToMono(io.reactivex.rxjava3.core.Maybe<T> source)

Adapt an RxJava 3 Maybe into a Mono instance.

Type Parameters:

T - the value type

Parameters:

source - the source Maybe

Returns:

the new Mono instance

monoToMaybe

public static <T> io.reactivex.rxjava3.core.Maybe<T> monoToMaybe(reactor.core.publisher.Mono<T> source)

Adapt a Mono instance into an RxJava 3 Maybe.

Type Parameters:

T - the value type

Parameters:

source - the source Mono

Returns:

the new Maybe instance