Skip navigation links
Reactor Addons: javadoc
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 
Skip navigation links
Reactor Addons: javadoc