Package rx.internal.operators
Class OnSubscribeTimerOnce
- java.lang.Object
-
- rx.internal.operators.OnSubscribeTimerOnce
-
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super java.lang.Long>>
,Function
,Observable.OnSubscribe<java.lang.Long>
public final class OnSubscribeTimerOnce extends java.lang.Object implements Observable.OnSubscribe<java.lang.Long>
Timer that emits a single 0L and completes after the specified time.- See Also:
- MSDN Observable.Timer
-
-
Constructor Summary
Constructors Constructor Description OnSubscribeTimerOnce(long time, 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
-
time
final long time
-
unit
final java.util.concurrent.TimeUnit unit
-
scheduler
final Scheduler scheduler
-
-
Constructor Detail
-
OnSubscribeTimerOnce
public OnSubscribeTimerOnce(long time, 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>>
-
-