Package rx.internal.schedulers

Class NewThreadScheduler

java.lang.Object

rx.Scheduler

rx.internal.schedulers.NewThreadScheduler

public final class NewThreadScheduler
extends Scheduler

Schedules work on a new thread.

Nested Class Summary

Nested classes/interfaces inherited from class rx.Scheduler

Scheduler.Worker

Field Summary

Fields

Modifier and Type	Field	Description
private final ThreadFactory	threadFactory

Constructor Summary

Constructors

Constructor	Description
NewThreadScheduler(ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
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

threadFactory

private final ThreadFactory threadFactory

Constructor Details

NewThreadScheduler

public NewThreadScheduler(ThreadFactory threadFactory)

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