Package akka.stream.stage
Interface OutHandler
-
- All Known Implementing Classes:
AbstractInOutHandler
,AbstractOutHandler
,ActorGraphInterpreter.BatchingActorInputBoundary
,ByteStringParser.ParsingLogic
,DeflateDecompressorBase.DecompressorParsingLogic
,GraphStageLogic.ConditionalTerminateOutput
,GraphStageLogic.EagerTerminateOutput$
,GraphStageLogic.IgnoreTerminateOutput$
,MergeHub.MergedSourceLogic
public interface OutHandler
Called when the output port has received a pull, and therefore ready to emit an element, i.e. {@link GraphStageLogic.push()} is now allowed to be called on this port.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
onDownstreamFinish()
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
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. {@link GraphStageLogic.push()} is now allowed to be called on this port.- Throws:
java.lang.Exception
-
-