Top Description Fields Constructors Methods

rx.internal.operators

public final Class OnSubscribeDelaySubscriptionWithSelector<T, U>

Class Inheritance

extends Object
implements Observable.OnSubscribe<T>

java.lang.Object
rx.internal.operators.OnSubscribeDelaySubscriptionWithSelector

All Implemented Interfaces

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

Type Parameters

<T>: the value type
<U>: the value type of the Observable triggering the delayed subscription

Imports

rx.*, .Observable.OnSubscribe, rx.exceptions.Exceptions, rx.functions.Func0, rx.observers.Subscribers

Delays the subscription until the Observable emits an event.

Field Summary

Modifier and Type	Field and Description
pack-priv final Observable<? extends T>	source
pack-priv final Func0<? extends Observable<U>>	subscriptionDelay

Constructor Summary

Access	Constructor and Description
public	OnSubscribeDelaySubscriptionWithSelector(Observable<? extends T> source, Func0<? extends Observable<U>> subscriptionDelay)

Method Summary

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

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

Field Detail

source	back to summary
pack-priv final Observable<? extends T> source

subscriptionDelay	back to summary
pack-priv final Func0<? extends Observable<U>> subscriptionDelay

Constructor Detail

OnSubscribeDelaySubscriptionWithSelector	back to summary
public OnSubscribeDelaySubscriptionWithSelector(Observable<? extends T> source, Func0<? extends Observable<U>> subscriptionDelay)

Method Detail

call

back to summary

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

Implements rx.functions.Action1.call.

Annotations

@Override