@Test
public void createComputationScheduler() {

    final String name = "ComputationSchedulerTest";
    ThreadFactory factory = new ThreadFactory() {
        @Override
        public Thread newThread(Runnable r) {
            return new Thread(r, name);
        }
    };
    final Scheduler customScheduler = RxJavaPlugins.createComputationScheduler(factory);
    RxJavaPlugins.setComputationSchedulerHandler(new Function<Scheduler, Scheduler>() {
        @Override
        public Scheduler apply(Scheduler scheduler) throws Exception {
            return customScheduler;
        }
    });
    try {
        verifyThread(Schedulers.computation(), name);
    } finally {
        customScheduler.shutdown();
        RxJavaPlugins.reset();
    }
}