Class OnSubscribeTimerPeriodically

java.lang.Object
rx.internal.operators.OnSubscribeTimerPeriodically
All Implemented Interfaces:
Action, Action1<Subscriber<? super Long>>, Function, Observable.OnSubscribe<Long>

public final class OnSubscribeTimerPeriodically extends Object implements Observable.OnSubscribe<Long>
Emit 0L after the initial period and ever increasing number after each period.
See Also:
  • Field Details

    • initialDelay

      final long initialDelay
    • period

      final long period
    • unit

      final TimeUnit unit
    • scheduler

      final Scheduler scheduler
  • Constructor Details

    • OnSubscribeTimerPeriodically

      public OnSubscribeTimerPeriodically(long initialDelay, long period, TimeUnit unit, Scheduler scheduler)
  • Method Details