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 OutHandlerCalled 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 voidonDownstreamFinish()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.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. {@link GraphStageLogic.push()} is now allowed to be called on this port.- Throws:
java.lang.Exception
-
-