Package rx.internal.operators
Class OperatorEagerConcatMap<T,R>
java.lang.Object
rx.internal.operators.OperatorEagerConcatMap<T,R>
- All Implemented Interfaces:
Func1<Subscriber<? super R>,
,Subscriber<? super T>> Function
,Observable.Operator<R,
T>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final int
(package private) final Func1
<? super T, ? extends Observable<? extends R>> private final int
-
Constructor Summary
ConstructorsConstructorDescriptionOperatorEagerConcatMap
(Func1<? super T, ? extends Observable<? extends R>> mapper, int bufferSize, int maxConcurrent) -
Method Summary
-
Field Details
-
mapper
-
bufferSize
final int bufferSize -
maxConcurrent
private final int maxConcurrent
-
-
Constructor Details
-
OperatorEagerConcatMap
public OperatorEagerConcatMap(Func1<? super T, ? extends Observable<? extends R>> mapper, int bufferSize, int maxConcurrent)
-
-
Method Details