Top Description Fields Constructors Methods
rx.internal.operators

public final Class OnSubscribeDelaySubscription<T>

extends Object
implements Observable.OnSubscribe<T>
Class Inheritance
All Implemented Interfaces
rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function
Type Parameters
<T>
the value type
Imports
java.util.concurrent.TimeUnit, rx.*, .Observable.OnSubscribe, .Scheduler.Worker, rx.functions.Action0, rx.observers.Subscribers
Delays the subscription to the source by the given amount, running on the given scheduler.

Field Summary

Modifier and TypeField and Description
pack-priv final Scheduler
scheduler

pack-priv final Observable<? extends T>
source

pack-priv final long
time

pack-priv final TimeUnit
unit

Constructor Summary

AccessConstructor and Description
public
OnSubscribeDelaySubscription(Observable<? extends T> source, long time, TimeUnit unit, Scheduler scheduler)

Method Summary

Modifier and TypeMethod and Description
public void
call(final Subscriber<? super T> s)

Implements rx.functions.Action1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

schedulerback to summary
pack-priv final Scheduler scheduler
sourceback to summary
pack-priv final Observable<? extends T> source
timeback to summary
pack-priv final long time
unitback to summary
pack-priv final TimeUnit unit

Constructor Detail

OnSubscribeDelaySubscriptionback to summary
public OnSubscribeDelaySubscription(Observable<? extends T> source, long time, TimeUnit unit, Scheduler scheduler)

Method Detail

callback to summary
public void call(final Subscriber<? super T> s)

Implements rx.functions.Action1.call.

Annotations
@Override