public final class FlowableScalarXMap extends Object
Modifier and Type | Method and Description |
---|---|
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.
|
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 Callable source's mapped Publisher.
|
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)
T
- the input value typeR
- the output value typesource
- the source Publishersubscriber
- the subscribermapper
- the function mapping a scalar value into a Publisherpublic static <T,U> Flowable<U> scalarXMap(T value, Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper)
T
- the scalar value typeU
- the output value typevalue
- the scalar value to mapmapper
- the function that gets the scalar value and should return
a Publisher that gets streamedCopyright © 2018 JBoss by Red Hat. All rights reserved.