Package akka.stream.stage
Interface OutHandler
-
- All Known Implementing Classes:
AbstractInOutHandler,AbstractOutHandler,GraphStageLogic.ConditionalTerminateOutput,GraphStageLogic.EagerTerminateOutput$,GraphStageLogic.IgnoreTerminateOutput$
public interface OutHandlerCollection of callbacks for an output port of aGraphStage
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description voidonDownstreamFinish()Deprecated.Call onDownstreamFinish with a cancellation cause.voidonDownstreamFinish(java.lang.Throwable cause)Called when the output port will no longer accept any new elements.voidonPull()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.ExceptionDeprecated.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.ExceptionCalled 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.ExceptionCalled when the output port has received a pull, and therefore ready to emit an element, i.e.GraphStageLogic.pushis now allowed to be called on this port.- Throws:
java.lang.Exception
-
-