Packages that use Scheduler

• Uses of Scheduler in rx

  Methods in rx with parameters of type Scheduler

  Modifier and Type	Method and Description
  Observable<List<T>>	Observable.buffer(long timespan, long timeshift, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits buffers of items it collects from the source Observable.
  Observable<List<T>>	Observable.buffer(long timespan, TimeUnit unit, int count, Scheduler scheduler) Returns an Observable that emits buffers of items it collects from the source Observable.
  Observable<List<T>>	Observable.buffer(long timespan, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits buffers of items it collects from the source Observable.
  Observable<T>	Observable.debounce(long timeout, TimeUnit unit, Scheduler scheduler) Returns an Observable that mirrors the source Observable, except that it drops items emitted by the source Observable that are followed by newer items before a timeout value expires on a specified Scheduler.
  Observable<T>	Observable.delay(long delay, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits the items emitted by the source Observable shifted forward in time by a specified delay.
  Observable<T>	Observable.delaySubscription(long delay, TimeUnit unit, Scheduler scheduler) Returns an Observable that delays the subscription to the source Observable by a given amount of time, both waiting and subscribing on a given Scheduler.
  static <T> Observable<T>	Observable.from(Future<? extends T> future, Scheduler scheduler) Converts a Future, operating on a specified Scheduler, into an Observable.
  static Observable<Long>	Observable.interval(long interval, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits a sequential number every specified interval of time, on a specified Scheduler.
  Observable<T>	Observable.observeOn(Scheduler scheduler) Modifies an Observable to perform its emissions and notifications on a specified Scheduler, asynchronously with an unbounded buffer.
  static Observable<Integer>	Observable.range(int start, int count, Scheduler scheduler) Returns an Observable that emits a sequence of Integers within a specified range, on a specified Scheduler.
  Observable<T>	Observable.repeat(long count, Scheduler scheduler) Returns an Observable that repeats the sequence of items emitted by the source Observable at most count times, on a particular Scheduler.
  Observable<T>	Observable.repeat(Scheduler scheduler) Returns an Observable that repeats the sequence of items emitted by the source Observable indefinitely, on a particular Scheduler.
  Observable<T>	Observable.repeatWhen(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler, Scheduler scheduler) Returns an Observable that emits the same values as the source Observable with the exception of an onCompleted.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying no more than bufferSize items that were emitted within a specified time window.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, int bufferSize, Scheduler scheduler) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying a maximum of bufferSize items.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.
  <R> Observable<R>	Observable.replay(Func1<? super Observable<T>,? extends Observable<R>> selector, Scheduler scheduler) Returns an Observable that emits items that are the results of invoking a specified selector on items emitted by a ConnectableObservable that shares a single subscription to the source Observable.
  ConnectableObservable<T>	Observable.replay(int bufferSize, long time, TimeUnit unit, Scheduler scheduler) Returns a ConnectableObservable that shares a single subscription to the source Observable and that replays a maximum of bufferSize items that are emitted within a specified time window.
  ConnectableObservable<T>	Observable.replay(int bufferSize, Scheduler scheduler) Returns a ConnectableObservable that shares a single subscription to the source Observable and replays at most bufferSize items emitted by that Observable.
  ConnectableObservable<T>	Observable.replay(long time, TimeUnit unit, Scheduler scheduler) Returns a ConnectableObservable that shares a single subscription to the source Observable and replays all items emitted by that Observable within a specified time window.
  ConnectableObservable<T>	Observable.replay(Scheduler scheduler) Returns a ConnectableObservable that shares a single subscription to the source Observable that will replay all of its items and notifications to any future Observer on the given Scheduler.
  Observable<T>	Observable.retryWhen(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler, Scheduler scheduler) Returns an Observable that emits the same values as the source observable with the exception of an onError.
  Observable<T>	Observable.sample(long period, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits the most recently emitted item (if any) emitted by the source Observable within periodic time intervals, where the intervals are defined on a particular Scheduler.
  Observable<T>	Observable.skip(long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that skips values emitted by the source Observable before a specified time window on a specified Scheduler elapses.
  Observable<T>	Observable.skipLast(long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that drops items emitted by the source Observable during a specified time window (defined on a specified scheduler) before the source completes.
  Observable<T>	Observable.subscribeOn(Scheduler scheduler) Asynchronously subscribes Observers to this Observable on the specified Scheduler.
  Observable<T>	Observable.take(long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits those items emitted by source Observable before a specified time (on a specified Scheduler) runs out.
  Observable<T>	Observable.takeLast(int count, long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits at most a specified number of items from the source Observable that were emitted in a specified window of time before the Observable completed, where the timing information is provided by a given Scheduler.
  Observable<T>	Observable.takeLast(long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits the items from the source Observable that were emitted in a specified window of time before the Observable completed, where the timing information is provided by a specified Scheduler.
  Observable<List<T>>	Observable.takeLastBuffer(int count, long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits a single List containing at most count items from the source Observable that were emitted during a specified window of time (on a specified Scheduler) before the source Observable completed.
  Observable<List<T>>	Observable.takeLastBuffer(long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits a single List containing those items from the source Observable that were emitted during a specified window of time before the source Observable completed, where the timing information is provided by the given Scheduler.
  Observable<T>	Observable.throttleFirst(long skipDuration, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits only the first item emitted by the source Observable during sequential time windows of a specified duration, where the windows are managed by a specified Scheduler.
  Observable<T>	Observable.throttleLast(long intervalDuration, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits only the last item emitted by the source Observable during sequential time windows of a specified duration, where the duration is governed by a specified Scheduler.
  Observable<T>	Observable.throttleWithTimeout(long timeout, TimeUnit unit, Scheduler scheduler) Returns an Observable that only emits those items emitted by the source Observable that are not followed by another emitted item within a specified time window, where the time window is governed by a specified Scheduler.
  Observable<TimeInterval<T>>	Observable.timeInterval(Scheduler scheduler) Returns an Observable that emits records of the time interval between consecutive items emitted by the source Observable, where this interval is computed on a specified Scheduler.
  Observable<T>	Observable.timeout(long timeout, TimeUnit timeUnit, Observable<? extends T> other, Scheduler scheduler) Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item using a specified Scheduler.
  Observable<T>	Observable.timeout(long timeout, TimeUnit timeUnit, Scheduler scheduler) Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item, where this policy is governed on a specified Scheduler.
  static Observable<Long>	Observable.timer(long initialDelay, long period, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits a 0L after the initialDelay and ever increasing numbers after each period of time thereafter, on a specified Scheduler.
  static Observable<Long>	Observable.timer(long delay, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits one item after a specified delay, on a specified Scheduler, and then completes.
  Observable<Timestamped<T>>	Observable.timestamp(Scheduler scheduler) Returns an Observable that emits each item emitted by the source Observable, wrapped in a Timestamped object whose timestamps are provided by a specified Scheduler.
  Observable<T>	Observable.unsubscribeOn(Scheduler scheduler) Modifies the source Observable so that subscribers will unsubscribe from it on a specified Scheduler.
  Observable<Observable<T>>	Observable.window(long timespan, long timeshift, TimeUnit unit, int count, Scheduler scheduler) Returns an Observable that emits windows of items it collects from the source Observable.
  Observable<Observable<T>>	Observable.window(long timespan, long timeshift, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits windows of items it collects from the source Observable.
  Observable<Observable<T>>	Observable.window(long timespan, TimeUnit unit, int count, Scheduler scheduler) Returns an Observable that emits windows of items it collects from the source Observable.
  Observable<Observable<T>>	Observable.window(long timespan, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits windows of items it collects from the source Observable.

• Uses of Scheduler in rx.internal.operators

  Methods in with parameters of type

  Modifier and Type	Method and Description
  static <T> Subject<T,T>	OperatorReplay.createScheduledSubject(Subject<T,T> subject, Scheduler scheduler) Creates a subject whose client observers will observe events propagated through the given wrapped subject.
  static <T> Observable<T>	OnSubscribeRedo.redo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
  static <T> Observable<T>	OnSubscribeRedo.repeat(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler, Scheduler scheduler)
  static <T> Observable<T>	OnSubscribeRedo.repeat(Observable<T> source, long count, Scheduler scheduler)
  static <T> Observable<T>	OnSubscribeRedo.repeat(Observable<T> source, Scheduler scheduler)
  static <T> Observable<T>	OnSubscribeRedo.retry(Observable<T> source, Func1<? super Observable<? extends Notification<?>>,? extends Observable<?>> notificationHandler, Scheduler scheduler)

  Constructors in rx.internal.operators with parameters of type Scheduler

  Constructor and Description
  	OnSubscribeDelaySubscription(Observable<? extends T> source, long time, TimeUnit unit, Scheduler scheduler)
  	OnSubscribeTimerOnce(long time, TimeUnit unit, Scheduler scheduler)
  	OnSubscribeTimerPeriodically(long initialDelay, long period, TimeUnit unit, Scheduler scheduler)
  	OperatorBufferWithTime(long timespan, long timeshift, TimeUnit unit, int count, Scheduler scheduler)
  	OperatorDebounceWithTime(long timeout, TimeUnit unit, Scheduler scheduler)
  	OperatorDelay(Observable<? extends T> source, long delay, TimeUnit unit, Scheduler scheduler)
  	OperatorObserveOn(Scheduler scheduler)
  	OperatorSampleWithTime(long time, TimeUnit unit, Scheduler scheduler)
  	OperatorSkipLastTimed(long time, TimeUnit unit, Scheduler scheduler)
  	OperatorSkipTimed(long time, TimeUnit unit, Scheduler scheduler)
  	OperatorSubscribeOn(Scheduler scheduler)
  	OperatorTakeLastTimed(int count, long time, TimeUnit unit, Scheduler scheduler)
  	OperatorTakeLastTimed(long time, TimeUnit unit, Scheduler scheduler)
  	OperatorTakeTimed(long time, TimeUnit unit, Scheduler scheduler)
  	OperatorThrottleFirst(long windowDuration, TimeUnit unit, Scheduler scheduler)
  	OperatorTimeInterval(Scheduler scheduler)
  	OperatorTimeout(long timeout, TimeUnit timeUnit, Observable<? extends T> other, Scheduler scheduler)
  	OperatorTimestamp(Scheduler scheduler)
  	OperatorUnsubscribeOn(Scheduler scheduler)
  	OperatorWindowWithTime(long timespan, long timeshift, TimeUnit unit, int size, Scheduler scheduler)

• Uses of Scheduler in rx.plugins

  Methods in rx.plugins that return Scheduler

  Modifier and Type	Method and Description
  Scheduler	RxJavaSchedulersHook.getComputationScheduler() Scheduler to return from Schedulers.computation() or null if default should be used.
  Scheduler	RxJavaSchedulersHook.getIOScheduler() Scheduler to return from Schedulers.io() or null if default should be used.
  Scheduler	RxJavaSchedulersHook.getNewThreadScheduler() Scheduler to return from Schedulers.newThread() or null if default should be used.

• Uses of Scheduler in rx.schedulers

  Subclasses of in

  Modifier and Type	Class and Description
  class	ImmediateScheduler Executes work immediately on the current thread.
  class	NewThreadScheduler Schedules work on a new thread.
  class	TestScheduler The TestScheduler is useful for debugging.
  class	TrampolineScheduler Schedules work on the current thread but does not execute immediately.

  Methods in rx.schedulers that return Scheduler

  Modifier and Type	Method and Description
  static Scheduler	Schedulers.computation() Creates and returns a Scheduler intended for computational work.
  static Scheduler	Schedulers.from(Executor executor) Converts an Executor into a new Scheduler instance.
  static Scheduler	Schedulers.immediate() Creates and returns a Scheduler that executes work immediately on the current thread.
  static Scheduler	Schedulers.io() Creates and returns a Scheduler intended for IO-bound work.
  static Scheduler	Schedulers.newThread() Creates and returns a Scheduler that creates a new Thread for each unit of work.
  static Scheduler	Schedulers.trampoline() Creates and returns a Scheduler that queues work on the current thread to be executed after the current work completes.

• Uses of Scheduler in rx.subjects

  Methods in rx.subjects with parameters of type Scheduler

  Modifier and Type	Method and Description
  static <T> ReplaySubject<T>	ReplaySubject.createWithTime(long time, TimeUnit unit, Scheduler scheduler) Creates a time-bounded replay subject.
  static <T> ReplaySubject<T>	ReplaySubject.createWithTimeAndSize(long time, TimeUnit unit, int size, Scheduler scheduler) Creates a time- and size-bounded replay subject.