Utility method for scheduling tasks periodically (at a fixed rate) by using Worker.schedule(Action0, long, TimeUnit).

Nested and Inner Type Summary

Modifier and Type	Class and Description
public static interface	SchedulePeriodicHelper.NowNanoSupplier Return the current time in nanoseconds.

Field Summary

Modifier and Type	Field and Description
public static final long	CLOCK_DRIFT_TOLERANCE_NANOS The tolerance for a clock drift in nanoseconds where the periodic scheduler will rebase.

Access	Constructor and Description
private	SchedulePeriodicHelper() Utility class.

Modifier and Type	Method and Description
public static Subscription	schedulePeriodically(final Scheduler.Worker worker, final Action0 action, long initialDelay, long period, TimeUnit unit, final SchedulePeriodicHelper.NowNanoSupplier nowNanoSupplier)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

CLOCK_DRIFT_TOLERANCE_NANOS back to summary

CLOCK_DRIFT_TOLERANCE_NANOS	back to summary
public static final long CLOCK_DRIFT_TOLERANCE_NANOS The tolerance for a clock drift in nanoseconds where the periodic scheduler will rebase. The associated system parameter, `rx.scheduler.drift-tolerance`, expects its value in minutes.

public static final long CLOCK_DRIFT_TOLERANCE_NANOS

The tolerance for a clock drift in nanoseconds where the periodic scheduler will rebase.

The associated system parameter, rx.scheduler.drift-tolerance, expects its value in minutes.

SchedulePeriodicHelper	back to summary
private SchedulePeriodicHelper() Utility class.

schedulePeriodically	back to summary
public static Subscription schedulePeriodically(final Scheduler.Worker worker, final Action0 action, long initialDelay, long period, TimeUnit unit, final SchedulePeriodicHelper.NowNanoSupplier nowNanoSupplier)

rx.internal.schedulers back to summary

Return the current time in nanoseconds.

Modifier and Type	Method and Description
public long	nowNanos()

nowNanos	back to summary
public long nowNanos()