Package rx.internal.operators
Class OnSubscribeTimerPeriodically
- java.lang.Object
-
- rx.internal.operators.OnSubscribeTimerPeriodically
-
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super java.lang.Long>>
,Function
,Observable.OnSubscribe<java.lang.Long>
public final class OnSubscribeTimerPeriodically extends java.lang.Object implements Observable.OnSubscribe<java.lang.Long>
Emit 0L after the initial period and ever increasing number after each period.- See Also:
- MSDN Observable.Timer
-
-
Field Summary
Fields Modifier and Type Field Description (package private) long
initialDelay
(package private) long
period
(package private) Scheduler
scheduler
(package private) java.util.concurrent.TimeUnit
unit
-
Constructor Summary
Constructors Constructor Description OnSubscribeTimerPeriodically(long initialDelay, long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
call(Subscriber<? super java.lang.Long> child)
-
-
-
Field Detail
-
initialDelay
final long initialDelay
-
period
final long period
-
unit
final java.util.concurrent.TimeUnit unit
-
scheduler
final Scheduler scheduler
-
-
Constructor Detail
-
OnSubscribeTimerPeriodically
public OnSubscribeTimerPeriodically(long initialDelay, long period, java.util.concurrent.TimeUnit unit, Scheduler scheduler)
-
-
Method Detail
-
call
public void call(Subscriber<? super java.lang.Long> child)
- Specified by:
call
in interfaceAction1<Subscriber<? super java.lang.Long>>
-
-