Package org.apache.pekko.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 a GraphStage

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onDownstreamFinish(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 Details

    • onDownstreamFinish

      void onDownstreamFinish(Throwable cause) throws 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:
      Exception

    • onPull

      void onPull() throws 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:
      Exception