Searched refs:onNextHandler (Results 1 – 1 of 1) sorted by relevance
251 final BiConsumer<? super Subscriber<? super T>, ? super Throwable> onNextHandler; field in SubmissionPublisher282 this.onNextHandler = handler; in SubmissionPublisher()349 new BufferedSubscription<T>(subscriber, executor, onNextHandler, in subscribe()1060 final BiConsumer<? super Subscriber<? super T>, ? super Throwable> onNextHandler; field in SubmissionPublisher.BufferedSubscription1086 ? super Throwable> onNextHandler, in BufferedSubscription() argument1091 this.onNextHandler = onNextHandler; in BufferedSubscription()1368 if ((h = onNextHandler) != null) in handleOnNext()