Top Description Fields Constructors Methods

rx.internal.operators

public final Class OnSubscribeTimerPeriodically

Class Inheritance

extends Object
implements Observable.OnSubscribe<Long>

java.lang.Object
rx.internal.operators.OnSubscribeTimerPeriodically

All Implemented Interfaces

rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function

Imports

java.util.concurrent.TimeUnit, rx.*, .Observable.OnSubscribe, .Scheduler.Worker, rx.exceptions.Exceptions, rx.functions.Action0

Emit 0L after the initial period and ever increasing number after each period.

See Also: MSDN Observable.Timer

Field Summary

Modifier and Type	Field and Description
pack-priv final long	initialDelay
pack-priv final long	period
pack-priv final Scheduler	scheduler
pack-priv final TimeUnit	unit

Constructor Summary

Access	Constructor and Description
public	OnSubscribeTimerPeriodically(long initialDelay, long period, TimeUnit unit, Scheduler scheduler)

Method Summary

Modifier and Type	Method and Description
public void	call(final Subscriber<? super Long> child) Implements rx.functions.Action1.call.

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

Field Detail

initialDelay	back to summary
pack-priv final long initialDelay

period	back to summary
pack-priv final long period

scheduler	back to summary
pack-priv final Scheduler scheduler

unit	back to summary
pack-priv final TimeUnit unit

Constructor Detail

OnSubscribeTimerPeriodically	back to summary
public OnSubscribeTimerPeriodically(long initialDelay, long period, TimeUnit unit, Scheduler scheduler)

Method Detail

call

back to summary

public void call(final Subscriber<? super Long> child)

Implements rx.functions.Action1.call.

Annotations

@Override