Class OnSubscribeCombineLatest<T,​R>

    • Field Detail

      • sourcesIterable

        final java.lang.Iterable<? extends Observable<? extends T>> sourcesIterable
      • combiner

        final FuncN<? extends R> combiner
      • bufferSize

        final int bufferSize
      • delayError

        final boolean delayError
    • Constructor Detail

      • OnSubscribeCombineLatest

        public OnSubscribeCombineLatest​(java.lang.Iterable<? extends Observable<? extends T>> sourcesIterable,
                                        FuncN<? extends R> combiner)
      • OnSubscribeCombineLatest

        public OnSubscribeCombineLatest​(Observable<? extends T>[] sources,
                                        java.lang.Iterable<? extends Observable<? extends T>> sourcesIterable,
                                        FuncN<? extends R> combiner,
                                        int bufferSize,
                                        boolean delayError)