ObservableTransformer (RxJava Javadoc 3.1.10) (original) (raw)

• Type Parameters:
  Upstream - the upstream value type
  Downstream - the downstream value type
  Functional Interface:
  This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ObservableTransformer<Upstream,Downstream>

• • Method Summary

  All Methods Instance Methods Abstract Methods

  Modifier and Type	Method and Description
  @NonNull ObservableSource<Downstream>	apply(@NonNull Observable<Upstream> upstream) Applies a function to the upstream Observable and returns an ObservableSource with optionally different element type.

• • Method Detail

     * #### apply  
     [@NonNull](../../../../io/reactivex/rxjava3/annotations/NonNull.html "annotation in io.reactivex.rxjava3.annotations")  
     [@NonNull](../../../../io/reactivex/rxjava3/annotations/NonNull.html "annotation in io.reactivex.rxjava3.annotations") [ObservableSource](../../../../io/reactivex/rxjava3/core/ObservableSource.html "interface in io.reactivex.rxjava3.core")<[Downstream](../../../../io/reactivex/rxjava3/core/ObservableTransformer.html "type parameter in ObservableTransformer")> apply([@NonNull](../../../../io/reactivex/rxjava3/annotations/NonNull.html "annotation in io.reactivex.rxjava3.annotations")  
                                                          [@NonNull](../../../../io/reactivex/rxjava3/annotations/NonNull.html "annotation in io.reactivex.rxjava3.annotations") [Observable](../../../../io/reactivex/rxjava3/core/Observable.html "class in io.reactivex.rxjava3.core")<[Upstream](../../../../io/reactivex/rxjava3/core/ObservableTransformer.html "type parameter in ObservableTransformer")> upstream)  
     Applies a function to the upstream [Observable](../../../../io/reactivex/rxjava3/core/Observable.html "class in io.reactivex.rxjava3.core") and returns an [ObservableSource](../../../../io/reactivex/rxjava3/core/ObservableSource.html "interface in io.reactivex.rxjava3.core") with optionally different element type.  
     Parameters:  
     `upstream` \- the upstream `Observable` instance  
     Returns:  
     the transformed `ObservableSource` instance