Searched refs:ConsumerTask (Results 1 – 1 of 1) sorted by relevance
969 static final class ConsumerTask<T> extends ForkJoinTask<Void> class in SubmissionPublisher972 ConsumerTask(BufferedSubscription<T> consumer) { in ConsumerTask() method in SubmissionPublisher.ConsumerTask1224 ConsumerTask<T> task = new ConsumerTask<T>(this); in tryStart()