Modifier and Type | Method and Description |
---|---|
static <T,R> org.reactivestreams.Subscriber<T> |
FlowableConcatMap.subscribe(org.reactivestreams.Subscriber<? super R> s,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
ErrorMode errorMode) |
Constructor and Description |
---|
FlowableConcatMap(Flowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
ErrorMode errorMode) |
FlowableConcatMapEager(Flowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int maxConcurrency,
int prefetch,
ErrorMode errorMode) |
FlowableConcatMapEagerPublisher(org.reactivestreams.Publisher<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int maxConcurrency,
int prefetch,
ErrorMode errorMode) |
FlowableConcatMapPublisher(org.reactivestreams.Publisher<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
ErrorMode errorMode) |
Constructor and Description |
---|
FlowableConcatMapCompletable(Flowable<T> source,
Function<? super T,? extends CompletableSource> mapper,
ErrorMode errorMode,
int prefetch) |
FlowableConcatMapMaybe(Flowable<T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper,
ErrorMode errorMode,
int prefetch) |
FlowableConcatMapSingle(Flowable<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper,
ErrorMode errorMode,
int prefetch) |
ObservableConcatMapCompletable(Observable<T> source,
Function<? super T,? extends CompletableSource> mapper,
ErrorMode errorMode,
int prefetch) |
ObservableConcatMapMaybe(Observable<T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper,
ErrorMode errorMode,
int prefetch) |
ObservableConcatMapSingle(Observable<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper,
ErrorMode errorMode,
int prefetch) |
Constructor and Description |
---|
ObservableConcatMap(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends U>> mapper,
int bufferSize,
ErrorMode delayErrors) |
ObservableConcatMapEager(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> mapper,
ErrorMode errorMode,
int maxConcurrency,
int prefetch) |
Constructor and Description |
---|
ParallelConcatMap(ParallelFlowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
ErrorMode errorMode) |
Modifier and Type | Method and Description |
---|---|
static ErrorMode |
ErrorMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ErrorMode[] |
ErrorMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.