Package rx.internal.operators

Class OperatorWithLatestFrom<T,U,R>

java.lang.Object
rx.internal.operators.OperatorWithLatestFrom<T,U,R>
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
All Implemented Interfaces:
Func1<Subscriber<? super R>,Subscriber<? super T>>, Function, Observable.Operator<R,T>
public final class OperatorWithLatestFrom<T,U,R> extends Object implements Observable.Operator<R,T>
Combines values from two sources only when the main source emits.

  • Field Details

    • resultSelector

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

    • other

      final Observable<? extends U> other

    • EMPTY

      static final Object EMPTY
      Indicates the other has not yet emitted a value.

  • Constructor Details

    • OperatorWithLatestFrom

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

  • Method Details