public final class NbpOnSubscribeScalarAsyncSource<T> extends java.lang.Object implements NbpObservable.NbpOnSubscribe<T>
| Constructor and Description |
|---|
NbpOnSubscribeScalarAsyncSource(java.util.concurrent.Callable<? extends T> callable) |
| Modifier and Type | Method and Description |
|---|---|
void |
accept(NbpObservable.NbpSubscriber<? super T> s) |
public NbpOnSubscribeScalarAsyncSource(java.util.concurrent.Callable<? extends T> callable)
public void accept(NbpObservable.NbpSubscriber<? super T> s)
accept in interface Consumer<NbpObservable.NbpSubscriber<? super T>>