public final class NbpOperatorCollect<T,U> extends java.lang.Object implements NbpObservable.NbpOperator<U,T>
| Constructor and Description |
|---|
NbpOperatorCollect(Supplier<? extends U> initialSupplier,
BiConsumer<? super U,? super T> collector) |
| Modifier and Type | Method and Description |
|---|---|
NbpObservable.NbpSubscriber<? super T> |
apply(NbpObservable.NbpSubscriber<? super U> t) |
public NbpOperatorCollect(Supplier<? extends U> initialSupplier, BiConsumer<? super U,? super T> collector)
public NbpObservable.NbpSubscriber<? super T> apply(NbpObservable.NbpSubscriber<? super U> t)
apply in interface Function<NbpObservable.NbpSubscriber<? super U>,NbpObservable.NbpSubscriber<? super T>>