public static interface NbpObservable.NbpOnSubscribe<T> extends Consumer<NbpObservable.NbpSubscriber<? super T>>
accept