Package rx.internal.schedulers

Class TrampolineScheduler

java.lang.Object

rx.Scheduler

rx.internal.schedulers.TrampolineScheduler

public final class TrampolineScheduler
extends Scheduler

Schedules work on the current thread but does not execute immediately. Work is put in a queue and executed after the current unit of work is completed.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	TrampolineScheduler.InnerCurrentThreadScheduler
(package private) static final class	TrampolineScheduler.TimedAction

Nested classes/interfaces inherited from class rx.Scheduler

Scheduler.Worker

Field Summary

Fields

Modifier and Type	Field	Description
static final TrampolineScheduler	INSTANCE

Constructor Summary

Constructors

Modifier	Constructor	Description
private	TrampolineScheduler()

Method Summary

Modifier and Type	Method	Description
(package private) static int	compare(int x, int y)
Scheduler.Worker	createWorker()	Retrieves or creates a new Scheduler.Worker that represents serial execution of actions.

Methods inherited from class rx.Scheduler

now, when

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final TrampolineScheduler INSTANCE

Constructor Details

TrampolineScheduler

private TrampolineScheduler()

Method Details

createWorker

public Scheduler.Worker createWorker()

Description copied from class: Scheduler

Retrieves or creates a new Scheduler.Worker that represents serial execution of actions.

When work is completed it should be unsubscribed using Subscription.unsubscribe().

Work on a Scheduler.Worker is guaranteed to be sequential.

Specified by:

createWorker in class Scheduler

Returns:

a Worker representing a serial queue of actions to be executed

compare

static int compare(int x,
 int y)