public final class ObservableScalarXMap extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ObservableScalarXMap.ScalarDisposable<T>
Represents a Disposable that signals one onNext followed by an onComplete.
|
Modifier and Type | Method and Description |
---|---|
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.
|
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 Callable source's mapped ObservableSource.
|
public static <T,R> boolean tryScalarXMapSubscribe(ObservableSource<T> source, Observer<? super R> observer, Function<? super T,? extends ObservableSource<? extends R>> mapper)
T
- the input value typeR
- the output value typesource
- the source ObservableSourceobserver
- the subscribermapper
- the function mapping a scalar value into an ObservableSourcepublic static <T,U> Observable<U> scalarXMap(T value, Function<? super T,? extends ObservableSource<? 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
an ObservableSource that gets streamedCopyright © 2018 JBoss by Red Hat. All rights reserved.