Package rx.internal.operators
Class OnSubscribeCombineLatest<T,R>
java.lang.Object
rx.internal.operators.OnSubscribeCombineLatest<T,R>
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super R>>
,Function
,Observable.OnSubscribe<R>
public final class OnSubscribeCombineLatest<T,R>
extends Object
implements Observable.OnSubscribe<R>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final int
(package private) final boolean
(package private) final Observable<? extends T>[]
(package private) final Iterable
<? extends Observable<? extends T>> -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeCombineLatest
(Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner) OnSubscribeCombineLatest
(Observable<? extends T>[] sources, Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner, int bufferSize, boolean delayError) -
Method Summary
-
Field Details
-
sources
-
sourcesIterable
-
combiner
-
bufferSize
final int bufferSize -
delayError
final boolean delayError
-
-
Constructor Details
-
OnSubscribeCombineLatest
public OnSubscribeCombineLatest(Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner) -
OnSubscribeCombineLatest
public OnSubscribeCombineLatest(Observable<? extends T>[] sources, Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner, int bufferSize, boolean delayError)
-
-
Method Details