Schedulers are one of the main components in RxJava. They are responsible for performing operations of Observable on different threads. They help to offload the time-consuming onto different threads. In this post we will learn the types of schedulers and when to use the different types.

 observable.subscribeOn(Schedulers.newThread())
 Observable.just(1,2,3,4)
    .subscribeOn(Schedulers.trampoline())
    .subscribe(onNext);
 Observable.just( 5,6, 7,8, 9)
    .subscribeOn(Schedulers.trampoline())
    .subscribe(onNext);

 Output:
    Number = 1
    Number = 2
    Number = 3
    Number = 4
    Number = 5
    Number = 6
    Number = 7
    Number = 8
    Number = 9

It is available as:

observable.subscribeOn(Schedulers.trampoline())

Immediate scheduler ( present in RxJava 1), just starts the task in a blocking way on the current thread that is active, disregarding which process is currently running