Top Description Fields Constructors Methods
rx.internal.operators

public final Class OperatorWithLatestFrom<T, U, R>

extends Object
implements Observable.Operator<R, T>
Class Inheritance
All Implemented Interfaces
rx.Observable.Operator, rx.functions.Func1, rx.functions.Function
Type Parameters
<T>
the element type of the main observable
<U>
the element type of the other observable that is merged into the main
<R>
the result element type
Imports
java.util.concurrent.atomic.AtomicReference, rx.*, .Observable.Operator, rx.exceptions.Exceptions, rx.functions.Func2, rx.observers.SerializedSubscriber
Combines values from two sources only when the main source emits.

Field Summary

Modifier and TypeField and Description
pack-priv static final Object
EMPTY

Indicates the other has not yet emitted a value.

pack-priv final Observable<? extends U>
other

pack-priv final Func2<? super T, ? super U, ? extends R>
resultSelector

Constructor Summary

AccessConstructor and Description
public
OperatorWithLatestFrom(Observable<? extends U> other, Func2<? super T, ? super U, ? extends R> resultSelector)

Method Summary

Modifier and TypeMethod and Description
public Subscriber<? super T>
call(Subscriber<? super R> child)

Implements rx.functions.Func1.call.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

EMPTYback to summary
pack-priv static final Object EMPTY

Indicates the other has not yet emitted a value.

otherback to summary
pack-priv final Observable<? extends U> other
resultSelectorback to summary
pack-priv final Func2<? super T, ? super U, ? extends R> resultSelector

Constructor Detail

OperatorWithLatestFromback to summary
public OperatorWithLatestFrom(Observable<? extends U> other, Func2<? super T, ? super U, ? extends R> resultSelector)

Method Detail

callback to summary
public Subscriber<? super T> call(Subscriber<? super R> child)

Implements rx.functions.Func1.call.

Annotations
@Override