public final class StreamTask.ActionContext extends Object
Constructor and Description |
---|
ActionContext() |
Modifier and Type | Method and Description |
---|---|
void |
actionsAvailable()
Calling this method signals that the mailbox-thread should continue invoking the default action, e.g.
|
void |
actionsUnavailable()
Calling this method signals that the mailbox-thread should (temporarily) stop invoking the default action,
e.g.
|
void |
allActionsCompleted()
This method must be called to end the stream task when all actions for the tasks have been performed.
|
public void allActionsCompleted()
public void actionsAvailable() throws InterruptedException
InterruptedException
- on interruption.public void actionsUnavailable() throws InterruptedException
InterruptedException
- on interruption.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.