A C D F I M O R S U

A

ActorScheduler - Class in reactor.adapter.akka

A Scheduler implementation that given an ActorSystem, creates a single Actor and routes all Scheduler/Worker calls to it.

C

completableToMono(Completable) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

Wraps a RxJava Completable into a Mono instance.

completableToMono(Completable) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

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

createWorker() - Method in class reactor.adapter.akka.ActorScheduler

createWorker() - Method in class reactor.adapter.rxjava.RxJava2Scheduler

createWorker() - Method in class reactor.adapter.rxjava.RxJava3Scheduler

D

dispose() - Method in class reactor.adapter.rxjava.RxJava3Scheduler

F

flowableToFlux(Flowable<T>) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

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

flowableToFlux(Flowable<T>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

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

fluxToFlowable(Flux<T>) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

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

fluxToFlowable(Flux<T>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

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

fluxToObservable(Flux<T>) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

Wraps a Flux instance into a RxJava Observable.

fluxToObservable(Flux<T>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

Adapt a Flux instance into an Rxjava3 Observable.

from(ActorSystem) - Static method in class reactor.adapter.akka.ActorScheduler

from(ActorRef) - Static method in class reactor.adapter.akka.ActorScheduler

from(Scheduler) - Static method in class reactor.adapter.rxjava.RxJava2Scheduler

from(Scheduler) - Static method in class reactor.adapter.rxjava.RxJava3Scheduler

Adapt an RxJava 3 Scheduler into a Reactor Scheduler.

I

isDisposed() - Method in class reactor.adapter.rxjava.RxJava3Scheduler

M

maybeToMono(Maybe<T>) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

Wraps an RxJava Maybe into a Mono instance.

maybeToMono(Maybe<T>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

Adapt an RxJava 3 Maybe into a Mono instance.

monoToCompletable(Mono<?>) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

Wraps a void-Mono instance into a RxJava Completable.

monoToCompletable(Mono<?>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

Adapt a Mono instance into an Rxjava3 Completable instance.

monoToCompletable(Mono<T>, Consumer<T>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

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).

monoToFlowable(Mono<T>) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

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

monoToFlowable(Mono<T>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

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

monoToMaybe(Mono<T>) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

Wraps Mono instance into an RxJava Maybe.

monoToMaybe(Mono<T>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

Adapt a Mono instance into an RxJava 3 Maybe.

monoToSingle(Mono<T>) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

Wraps a Mono instance into a RxJava Single.

monoToSingle(Mono<T>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

Adapt a Mono instance into an Rxjava3 Single.

O

observableToFlux(Observable<T>, BackpressureStrategy) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

Wraps an RxJava Observable and applies the given backpressure trategy.

observableToFlux(Observable<T>, BackpressureStrategy) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

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.

R

reactor.adapter.akka - package reactor.adapter.akka

reactor.adapter.rxjava - package reactor.adapter.rxjava

Adapters between RxJava classes (both 2.x and 3.x) and Reactor classes.

resetReactorCoreSchedulers() - Static method in class reactor.adapter.rxjava.RxJava2Schedulers

Restores the RxJava 2 standard Schedulers to their default values.

RxJava2Adapter - Class in reactor.adapter.rxjava

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

RxJava2Scheduler - Class in reactor.adapter.rxjava

Wraps an RxJava scheduler and exposes it as a Reactor-Core Scheduler.

RxJava2Schedulers - Class in reactor.adapter.rxjava

Replace the standard schedulers of RxJava 2 or Reactor-Core with the schedulers of the other library.

RxJava3Adapter - Class in reactor.adapter.rxjava

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

RxJava3Scheduler - Class in reactor.adapter.rxjava

Wraps an RxJava 3 Scheduler and exposes it as a Reactor-Core Scheduler.

S

schedule(Runnable) - Method in class reactor.adapter.akka.ActorScheduler

schedule(Runnable) - Method in class reactor.adapter.rxjava.RxJava2Scheduler

schedule(Runnable, long, TimeUnit) - Method in class reactor.adapter.rxjava.RxJava2Scheduler

schedule(Runnable) - Method in class reactor.adapter.rxjava.RxJava3Scheduler

schedule(Runnable, long, TimeUnit) - Method in class reactor.adapter.rxjava.RxJava3Scheduler

schedulePeriodically(Runnable, long, long, TimeUnit) - Method in class reactor.adapter.rxjava.RxJava2Scheduler

schedulePeriodically(Runnable, long, long, TimeUnit) - Method in class reactor.adapter.rxjava.RxJava3Scheduler

singleToMono(Single<T>) - Static method in class reactor.adapter.rxjava.RxJava2Adapter

Wraps a RxJava Single into a Mono instance.

singleToMono(Single<T>) - Static method in class reactor.adapter.rxjava.RxJava3Adapter

Adapt an Rxjava3 Single into a Mono instance.

start() - Method in class reactor.adapter.rxjava.RxJava3Scheduler

U

useReactorCoreSchedulers() - Static method in class reactor.adapter.rxjava.RxJava2Schedulers

The RxJava 2 standard Schedulers will be replaced by their Reactor-Core counterparts; both libraries will run on the Reactor-Core schedulers.

A C D F I M O R S U