Class OperatorMapNotification<T,R>

java.lang.Object
rx.internal.operators.OperatorMapNotification<T,R>
Type Parameters:
T - the input value type
R - the output value type
All Implemented Interfaces:
Func1<Subscriber<? super R>,Subscriber<? super T>>, Function, Observable.Operator<R,T>

public final class OperatorMapNotification<T,R> extends Object implements Observable.Operator<R,T>
Applies a function of your choosing to every item emitted by an Observable, and emits the results of this transformation as a new Observable.

  • Field Details

    • onNext

      final Func1<? super T,? extends R> onNext
    • onError

      final Func1<? super Throwable,? extends R> onError
    • onCompleted

      final Func0<? extends R> onCompleted
  • Constructor Details

    • OperatorMapNotification

      public OperatorMapNotification(Func1<? super T,? extends R> onNext, Func1<? super Throwable,? extends R> onError, Func0<? extends R> onCompleted)
  • Method Details