Searched refs:consumeSubscribe (Results 1 – 1 of 1) sorted by relevance
1380 consumeSubscribe(s); in subscribeOnOpen()1383 final void consumeSubscribe(Subscriber<? super T> s) { in consumeSubscribe() method in SubmissionPublisher.BufferedSubscription