Skip to content

Instantly share code, notes, and snippets.

@amadeu01
Created May 15, 2018 19:17
Show Gist options
  • Save amadeu01/b41ed03eb51e8fd429f7f6a7bf3a8490 to your computer and use it in GitHub Desktop.
Save amadeu01/b41ed03eb51e8fd429f7f6a7bf3a8490 to your computer and use it in GitHub Desktop.
Test Rxjava
@BeforeClass
public static void setUpRxSchedulers() {
Scheduler immediate = new Scheduler() {
@Override
public Disposable scheduleDirect(@NonNull Runnable run, long delay, @NonNull TimeUnit unit) {
// this prevents StackOverflowErrors when scheduling with a delay
return super.scheduleDirect(run, 0, unit);
}
@Override
public Worker createWorker() {
return new ExecutorScheduler.ExecutorWorker(Runnable::run);
}
};
RxJavaPlugins.setInitIoSchedulerHandler(scheduler -> immediate);
RxJavaPlugins.setInitComputationSchedulerHandler(scheduler -> immediate);
RxJavaPlugins.setInitNewThreadSchedulerHandler(scheduler -> immediate);
RxJavaPlugins.setInitSingleSchedulerHandler(scheduler -> immediate);
RxAndroidPlugins.setInitMainThreadSchedulerHandler(scheduler -> immediate);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment