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>
  • Field Details

    • sources

      final Observable<? extends T>[] sources
    • sourcesIterable

      final Iterable<? extends Observable<? extends T>> sourcesIterable
    • combiner

      final FuncN<? extends R> 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