hu.akarnokd.rxjava2

Class Scheduler.Worker

java.lang.Object

hu.akarnokd.rxjava2.Scheduler.Worker

All Implemented Interfaces:

Disposable

Direct Known Subclasses:

ExecutorScheduler.ExecutorWorker, NewThreadWorker

Enclosing class:

Scheduler

public abstract static class Scheduler.Worker
extends java.lang.Object
implements Disposable

Constructor Summary

Constructors

Constructor and Description
Worker()

Method Summary

Modifier and Type	Method and Description
long	now(java.util.concurrent.TimeUnit unit) Returns the 'current time' of the Worker in the specified time unit.
Disposable	schedule(java.lang.Runnable run)
abstract Disposable	schedule(java.lang.Runnable run, long delay, java.util.concurrent.TimeUnit unit)
Disposable	schedulePeriodically(java.lang.Runnable run, long initialDelay, long period, java.util.concurrent.TimeUnit unit)

Methods inherited from class java.lang.Object

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

Methods inherited from interface hu.akarnokd.rxjava2.disposables.Disposable

dispose

Constructor Detail

Worker

public Worker()

Method Detail

schedule

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

schedule

public Disposable schedule(java.lang.Runnable run)

schedulePeriodically

public Disposable schedulePeriodically(java.lang.Runnable run,
                                       long initialDelay,
                                       long period,
                                       java.util.concurrent.TimeUnit unit)

now

public long now(java.util.concurrent.TimeUnit unit)

Returns the 'current time' of the Worker in the specified time unit.

Parameters:

unit - the time unit

Returns:

the 'current time'