Top Description Fields Constructors Methods
rx.internal.schedulers

public final Class NewThreadScheduler

extends Scheduler
Class Inheritance
Imports
java.util.concurrent.ThreadFactory, rx.Scheduler
Schedules work on a new thread.

Field Summary

Modifier and TypeField and Description
private final ThreadFactory
threadFactory

Constructor Summary

AccessConstructor and Description
public
NewThreadScheduler(ThreadFactory threadFactory)

Method Summary

Modifier and TypeMethod and Description
public Scheduler.Worker
createWorker()

Implements abstract rx.Scheduler.createWorker.

Retrieves or creates a new Scheduler.Worker that represents serial execution of actions.
Inherited from rx.Scheduler:
nowwhen

Field Detail

threadFactoryback to summary
private final ThreadFactory threadFactory

Constructor Detail

NewThreadSchedulerback to summary
public NewThreadScheduler(ThreadFactory threadFactory)

Method Detail

createWorkerback to summary
public Scheduler.Worker createWorker()

Implements abstract rx.Scheduler.createWorker.

Doc from rx.Scheduler.createWorker.

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

When work is completed it should be unsubscribed using Scheduler.Worker#unsubscribe().

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

Returns:Scheduler.Worker

a Worker representing a serial queue of actions to be executed

Annotations
@Override