akka.stream.stage

Interface OutHandler

All Known Implementing Classes:

AbstractInOutHandler, AbstractOutHandler, ByteStringParser.ParsingLogic, DeflateDecompressorBase.DecompressorParsingLogic, GraphStageLogic.ConditionalTerminateOutput, GraphStageLogic.EagerTerminateOutput$, GraphStageLogic.IgnoreTerminateOutput$, IteratorInterpreter.IteratorUpstream, MergeHub.MergedSourceLogic

public interface OutHandler

Collection of callbacks for an output port of a GraphStage

Method Summary

Modifier and Type	Method and 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

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

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