hu.akarnokd.rxjava2.internal.schedulers

Class ExecutorScheduler.ExecutorWorker

java.lang.Object

hu.akarnokd.rxjava2.Scheduler.Worker

hu.akarnokd.rxjava2.internal.schedulers.ExecutorScheduler.ExecutorWorker

All Implemented Interfaces:

Disposable, java.lang.Runnable

Enclosing class:

ExecutorScheduler

public static final class ExecutorScheduler.ExecutorWorker
extends Scheduler.Worker
implements java.lang.Runnable

Constructor Summary

Constructors

Constructor and Description
ExecutorWorker(java.util.concurrent.Executor executor)

Method Summary

Modifier and Type	Method and Description
void	dispose() Dispose the resource, the operation should be idempotent.
void	run()
Disposable	schedule(java.lang.Runnable run)
Disposable	schedule(java.lang.Runnable run, long delay, java.util.concurrent.TimeUnit unit)

Methods inherited from class hu.akarnokd.rxjava2.Scheduler.Worker

now, schedulePeriodically

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorWorker

public ExecutorWorker(java.util.concurrent.Executor executor)

Method Detail

schedule

public Disposable schedule(java.lang.Runnable run)

Overrides:

schedule in class Scheduler.Worker

schedule

public Disposable schedule(java.lang.Runnable run,
                           long delay,
                           java.util.concurrent.TimeUnit unit)

Specified by:

schedule in class Scheduler.Worker

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

run

public void run()

Specified by:

run in interface java.lang.Runnable