rx.internal.operators

Class OnSubscribeCombineLatest<T,R>

  • Type Parameters:
    T - the common basetype of the source values
    R - the result type of the combinator function
    All Implemented Interfaces:
    Action, Action1<Subscriber<? super R>>, Function, Observable.OnSubscribe<R> 

    public final class OnSubscribeCombineLatest<T,R>
extends Object
implements Observable.OnSubscribe<R>
    Returns an Observable that combines the emissions of multiple source observables. Once each source Observable has emitted at least one item, combineLatest emits an item whenever any of the source Observables emits an item, by combining the latest emissions from each source Observable with a specified function.

    • Constructor Detail

      • OnSubscribeCombineLatest

        public OnSubscribeCombineLatest(List<? extends Observable<? extends T>> sources,
                                FuncN<? extends R> combinator)

    • Method Detail