Interface OutHandler

    • Method Detail

      • onDownstreamFinish

        void onDownstreamFinish()
                         throws java.lang.Exception
        Deprecated.
        Call onDownstreamFinish with a cancellation cause. Since 2.6.0.
        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
      • onDownstreamFinish

        void onDownstreamFinish​(java.lang.Throwable cause)
                         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. GraphStageLogic.push is now allowed to be called on this port.
        Throws:
        java.lang.Exception