public final class NbpOnSubscribeGenerate<T,S> extends java.lang.Object implements NbpObservable.NbpOnSubscribe<T>
| Constructor and Description |
|---|
NbpOnSubscribeGenerate(Supplier<S> stateSupplier,
BiFunction<S,NbpObservable.NbpSubscriber<T>,S> generator,
Consumer<? super S> disposeState) |
| Modifier and Type | Method and Description |
|---|---|
void |
accept(NbpObservable.NbpSubscriber<? super T> s) |
public NbpOnSubscribeGenerate(Supplier<S> stateSupplier, BiFunction<S,NbpObservable.NbpSubscriber<T>,S> generator, Consumer<? super S> disposeState)
public void accept(NbpObservable.NbpSubscriber<? super T> s)
accept in interface Consumer<NbpObservable.NbpSubscriber<? super T>>