Top Description Fields Constructors Methods
rx.internal.operators

public final Class OperatorDelayWithSelector<T, V>

extends Object
implements Observable.Operator<T, T>
Class Inheritance
All Implemented Interfaces
rx.Observable.Operator, rx.functions.Func1, rx.functions.Function
Type Parameters
<T>
the item type
<V>
the value type of the item-delaying observable
Imports
rx.*, .Observable.Operator, rx.exceptions.Exceptions, rx.functions.Func1, rx.observers.*, rx.subjects.PublishSubject
Delay the subscription and emission of the source items by a per-item observable that fires its first element.

Field Summary

Modifier and TypeField and Description
pack-priv final Func1<? super T, ? extends Observable<V>>
itemDelay

pack-priv final Observable<? extends T>
source

Constructor Summary

AccessConstructor and Description
public
OperatorDelayWithSelector(Observable<? extends T> source, Func1<? super T, ? extends Observable<V>> itemDelay)

Method Summary

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

Implements rx.functions.Func1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

itemDelayback to summary
pack-priv final Func1<? super T, ? extends Observable<V>> itemDelay
sourceback to summary
pack-priv final Observable<? extends T> source

Constructor Detail

OperatorDelayWithSelectorback to summary
public OperatorDelayWithSelector(Observable<? extends T> source, Func1<? super T, ? extends Observable<V>> itemDelay)

Method Detail

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

Implements rx.functions.Func1.call.

Annotations
@Override