Class ObservableScalarXMap

java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.ObservableScalarXMap

public final class ObservableScalarXMap extends Object
Utility classes to work with scalar-sourced XMap operators (where X == { flat, concat, switch }).
  • Constructor Details

    • ObservableScalarXMap

      private ObservableScalarXMap()
      Utility class.
  • Method Details

    • tryScalarXMapSubscribe

      public static <T, R> boolean tryScalarXMapSubscribe(ObservableSource<T> source, Observer<? super R> observer, Function<? super T,? extends ObservableSource<? extends R>> mapper)
      Tries to subscribe to a possibly Supplier source's mapped ObservableSource.
      Type Parameters:
      T - the input value type
      R - the output value type
      Parameters:
      source - the source ObservableSource
      observer - the subscriber
      mapper - the function mapping a scalar value into an ObservableSource
      Returns:
      true if successful, false if the caller should continue with the regular path.
    • scalarXMap

      public static <T, U> Observable<U> scalarXMap(T value, Function<? super T,? extends ObservableSource<? extends U>> mapper)
      Maps a scalar value into an Observable and emits its values.
      Type Parameters:
      T - the scalar value type
      U - the output value type
      Parameters:
      value - the scalar value to map
      mapper - the function that gets the scalar value and should return an ObservableSource that gets streamed
      Returns:
      the new Observable instance