Searched refs:consumeNext (Results 1 – 1 of 1) sorted by relevance
1343 else if (!consumeNext(s, x)) in takeItems()1350 final boolean consumeNext(Subscriber<? super T> s, Object x) { in consumeNext() method in SubmissionPublisher.BufferedSubscription