Interface OutHandler

    • 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