reactor.adapter.rxjava

Class RxJava2Schedulers

java.lang.Object

reactor.adapter.rxjava.RxJava2Schedulers

public final class RxJava2Schedulers
extends Object

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

This can prevent having two sets of worker pools when both libraries are in use.

Method Summary

Modifier and Type	Method and Description
static void	resetReactorCoreSchedulers() Restores the RxJava 2 standard Schedulers to their default values.
static void	useReactorCoreSchedulers() The RxJava 2 standard Schedulers will be replaced by their Reactor-Core counterparts; both libraries will run on the Reactor-Core schedulers.

Methods inherited from class java.lang.Object

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

Method Detail

useReactorCoreSchedulers

public static void useReactorCoreSchedulers()

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

Call this before interacting with RxJava 2.

resetReactorCoreSchedulers

public static void resetReactorCoreSchedulers()

Restores the RxJava 2 standard Schedulers to their default values.