Package akka.stream.stage
Interface OutHandler
-
- All Known Implementing Classes:
AbstractInOutHandler
,AbstractOutHandler
,GraphStageLogic.ConditionalTerminateOutput
,GraphStageLogic.EagerTerminateOutput$
,GraphStageLogic.IgnoreTerminateOutput$
public interface OutHandler
Collection of callbacks for an output port of aGraphStage
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description void
onDownstreamFinish()
Deprecated.Call onDownstreamFinish with a cancellation cause.void
onDownstreamFinish(java.lang.Throwable cause)
Called when the output port will no longer accept any new elements.void
onPull()
Called when the output port has received a pull, and therefore ready to emit an element, i.e.
-
-
-
Method Detail
-
onDownstreamFinish
void onDownstreamFinish() throws java.lang.Exception
Deprecated.Call onDownstreamFinish with a cancellation cause. Since 2.6.0.Called when the output port will no longer accept any new elements. After this callback no other callbacks will be called for this port.- Throws:
java.lang.Exception
-
onDownstreamFinish
void onDownstreamFinish(java.lang.Throwable cause) throws java.lang.Exception
Called when the output port will no longer accept any new elements. After this callback no other callbacks will be called for this port.- Throws:
java.lang.Exception
-
onPull
void onPull() throws java.lang.Exception
Called when the output port has received a pull, and therefore ready to emit an element, i.e.GraphStageLogic.push
is now allowed to be called on this port.- Throws:
java.lang.Exception
-
-