com.github.davidmoten.rx2

Class SchedulerHelper

java.lang.Object

com.github.davidmoten.rx2.SchedulerHelper

public final class SchedulerHelper
extends Object

Method Summary

Modifier and Type	Method and Description
static void	blockUntilWorkFinished(io.reactivex.Scheduler scheduler, int numThreads)
static void	blockUntilWorkFinished(io.reactivex.Scheduler scheduler, int numThreads, long timeout, TimeUnit unit)
static io.reactivex.Scheduler	withThreadId(io.reactivex.Scheduler scheduler, String id)
static io.reactivex.Scheduler	withThreadIdFromCallSite(io.reactivex.Scheduler scheduler)

Methods inherited from class java.lang.Object

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

Method Detail

withThreadIdFromCallSite

public static io.reactivex.Scheduler withThreadIdFromCallSite(io.reactivex.Scheduler scheduler)

withThreadId

public static io.reactivex.Scheduler withThreadId(io.reactivex.Scheduler scheduler,
                                                  String id)

blockUntilWorkFinished

public static void blockUntilWorkFinished(io.reactivex.Scheduler scheduler,
                                          int numThreads,
                                          long timeout,
                                          TimeUnit unit)

blockUntilWorkFinished

public static void blockUntilWorkFinished(io.reactivex.Scheduler scheduler,
                                          int numThreads)