public final class OnSubscribeCombineLatest<T,R> extends Object implements Observable.OnSubscribe<R>
Constructor and Description |
---|
OnSubscribeCombineLatest(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) |
public OnSubscribeCombineLatest(Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner)
public OnSubscribeCombineLatest(Observable<? extends T>[] sources, Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner, int bufferSize, boolean delayError)
public void call(Subscriber<? super R> s)
call
in interface Action1<Subscriber<? super R>>
Copyright © 2018. All rights reserved.