static final class SubmissionPublisher.ConsumerTask<T>
extends java.util.concurrent.ForkJoinTask<java.lang.Void>
implements java.lang.Runnable, java.util.concurrent.CompletableFuture.AsynchronousCompletionTask
Modifier and Type | Field and Description |
---|---|
(package private) SubmissionPublisher.BufferedSubscription<T> |
consumer |
Constructor and Description |
---|
ConsumerTask(SubmissionPublisher.BufferedSubscription<T> consumer) |
Modifier and Type | Method and Description |
---|---|
boolean |
exec() |
java.lang.Void |
getRawResult() |
void |
run() |
void |
setRawResult(java.lang.Void v) |
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork
final SubmissionPublisher.BufferedSubscription<T> consumer
ConsumerTask(SubmissionPublisher.BufferedSubscription<T> consumer)
public final java.lang.Void getRawResult()
getRawResult
in class java.util.concurrent.ForkJoinTask<java.lang.Void>
public final void setRawResult(java.lang.Void v)
setRawResult
in class java.util.concurrent.ForkJoinTask<java.lang.Void>
public final boolean exec()
exec
in class java.util.concurrent.ForkJoinTask<java.lang.Void>
public final void run()
run
in interface java.lang.Runnable