hu.akarnokd.rxjava2.internal.operators.nbp

Class NbpOnSubscribeCombineLatest<T,R>

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeCombineLatest<T,R>

All Implemented Interfaces:

Consumer<NbpObservable.NbpSubscriber<? super R>>, NbpObservable.NbpOnSubscribe<R>

public final class NbpOnSubscribeCombineLatest<T,R>
extends java.lang.Object
implements NbpObservable.NbpOnSubscribe<R>

Constructor Summary

Constructors

Constructor and Description
NbpOnSubscribeCombineLatest(NbpObservable<? extends T>[] sources, java.lang.Iterable<? extends NbpObservable<? extends T>> sourcesIterable, Function<? super java.lang.Object[],? extends R> combiner, int bufferSize, boolean delayError)

Method Summary

Modifier and Type	Method and Description
void	accept(NbpObservable.NbpSubscriber<? super R> s)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NbpOnSubscribeCombineLatest

public NbpOnSubscribeCombineLatest(NbpObservable<? extends T>[] sources,
                                   java.lang.Iterable<? extends NbpObservable<? extends T>> sourcesIterable,
                                   Function<? super java.lang.Object[],? extends R> combiner,
                                   int bufferSize,
                                   boolean delayError)

Method Detail

accept

public void accept(NbpObservable.NbpSubscriber<? super R> s)

Specified by:

accept in interface Consumer<NbpObservable.NbpSubscriber<? super R>>