Searched defs: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.ConsumerTask