Class FlowableScalarXMap
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableScalarXMap
Utility classes to work with scalar-sourced XMap operators (where X == { flat, concat, switch }).
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
Maps a scalar value to a Publisher and subscribes to it. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T,
U> Flowable <U> scalarXMap
(T value, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper) Maps a scalar value into a Publisher and emits its values.static <T,
R> boolean tryScalarXMapSubscribe
(org.reactivestreams.Publisher<T> source, org.reactivestreams.Subscriber<? super R> subscriber, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper) Tries to subscribe to a possibly Supplier source's mapped Publisher.
-
Constructor Details
-
FlowableScalarXMap
private FlowableScalarXMap()Utility class.
-
-
Method Details
-
tryScalarXMapSubscribe
public static <T,R> boolean tryScalarXMapSubscribe(org.reactivestreams.Publisher<T> source, org.reactivestreams.Subscriber<? super R> subscriber, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper) Tries to subscribe to a possibly Supplier source's mapped Publisher.- Type Parameters:
T
- the input value typeR
- the output value type- Parameters:
source
- the source Publishersubscriber
- the subscribermapper
- the function mapping a scalar value into a Publisher- Returns:
- true if successful, false if the caller should continue with the regular path.
-
scalarXMap
public static <T,U> Flowable<U> scalarXMap(T value, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper) Maps a scalar value into a Publisher and emits its values.- Type Parameters:
T
- the scalar value typeU
- the output value type- Parameters:
value
- the scalar value to mapmapper
- the function that gets the scalar value and should return a Publisher that gets streamed- Returns:
- the new Flowable instance
-