protected static final class MailboxProcessor.MailboxController extends Object implements MailboxDefaultAction.Controller
MailboxDefaultAction.Controller
that is connected to a MailboxProcessor
instance.Modifier | Constructor and Description |
---|---|
protected |
MailboxController(MailboxProcessor mailboxProcessor) |
Modifier and Type | Method and Description |
---|---|
void |
allActionsCompleted()
This method must be called to end the stream task when all actions for the tasks have
been performed.
|
MailboxDefaultAction.Suspension |
suspendDefaultAction()
Calling this method signals that the mailbox-thread should (temporarily) stop invoking
the default action, e.g.
|
protected MailboxController(MailboxProcessor mailboxProcessor)
public void allActionsCompleted()
MailboxDefaultAction.Controller
allActionsCompleted
in interface MailboxDefaultAction.Controller
public MailboxDefaultAction.Suspension suspendDefaultAction()
MailboxDefaultAction.Controller
suspendDefaultAction
in interface MailboxDefaultAction.Controller
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.