public interface DetachedContext<Out> extends Context<Out>
DetachedStage
.
#hold
stops execution and at the same time putting the stage in a holding state.
If the stage is in a holding state it contains one absorbed signal, therefore in
this state the only possible command to call is pushAndPull(Out)
which results in two
events making the balance right again: 1 hold + 1 external event = 2 external event
Modifier and Type | Method and Description |
---|---|
DownstreamDirective |
holdDownstream() |
DownstreamDirective |
holdDownstreamAndPull() |
UpstreamDirective |
holdUpstream() |
UpstreamDirective |
holdUpstreamAndPush(Out elem) |
boolean |
isHoldingBoth()
|
boolean |
isHoldingDownstream() |
boolean |
isHoldingUpstream() |
FreeDirective |
pushAndPull(Out elem) |
absorbTermination, fail, finish, isFinishing, pull, push, pushAndFinish
attributes, materializer
UpstreamDirective holdUpstream()
UpstreamDirective holdUpstreamAndPush(Out elem)
DownstreamDirective holdDownstream()
DownstreamDirective holdDownstreamAndPull()
boolean isHoldingBoth()
boolean isHoldingUpstream()
boolean isHoldingDownstream()
FreeDirective pushAndPull(Out elem)