Top Inners Fields Constructors Methods
io.reactivex.internal.operators.flowable

public final Class FlowableConcatMap<T, R>

extends AbstractFlowableWithUpstream<T, R>
Class Inheritance
Imports
java.util.concurrent.Callable, java.util.concurrent.atomic.*, org.reactivestreams.*, io.reactivex.*, io.reactivex.exceptions.Exceptions, io.reactivex.functions.Function, io.reactivex.internal.functions.ObjectHelper, io.reactivex.internal.fuseable.*, io.reactivex.internal.queue.SpscArrayQueue, io.reactivex.internal.subscriptions.*, io.reactivex.internal.util.*, io.reactivex.plugins.RxJavaPlugins

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv abstract static class
FlowableConcatMap.BaseConcatMapSubscriber<T, R>

pack-priv static class
FlowableConcatMap.ConcatMapDelayed<T, R>

pack-priv static class
FlowableConcatMap.ConcatMapImmediate<T, R>

pack-priv static class
FlowableConcatMap.ConcatMapInner<R>

pack-priv static interface
FlowableConcatMap.ConcatMapSupport<T>

pack-priv static class
FlowableConcatMap.SimpleScalarSubscription<T>

Field Summary

Modifier and TypeField and Description
pack-priv final ErrorMode
errorMode

pack-priv final Function<? super T, ? extends Publisher<? extends R>>
mapper

pack-priv final int
prefetch

Inherited from io.reactivex.internal.operators.flowable.AbstractFlowableWithUpstream:
source

Constructor Summary

AccessConstructor and Description
public
FlowableConcatMap(Flowable<T> source, Function<? super T, ? extends Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode)

Method Summary

Modifier and TypeMethod and Description
public static <T, R> Subscriber<T>
subscribe(Subscriber<? super R> s, Function<? super T, ? extends Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode)

protected void
subscribeActual(Subscriber<? super R>
the incoming Subscriber, never null
s)

Implements abstract io.reactivex.Flowable.subscribeActual.

Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming Subscribers.
Inherited from io.reactivex.internal.operators.flowable.AbstractFlowableWithUpstream:
source