Package rx.internal.operators
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 Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeTimerPeriodically
(long initialDelay, long period, TimeUnit unit, Scheduler scheduler) -
Method Summary
-
Field Details
-
initialDelay
final long initialDelay -
period
final long period -
unit
-
scheduler
-
-
Constructor Details
-
OnSubscribeTimerPeriodically
-
-
Method Details
-
call
- Specified by:
call
in interfaceAction1<Subscriber<? super Long>>
-