Class ObservableScalarXMap


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

      • ObservableScalarXMap

        private ObservableScalarXMap()
        Utility class.
    • Method Detail

      • 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