Interface InHandler

    • Method Detail

      • onPush

        void onPush()
             throws java.lang.Exception
        Called when the input port has a new element available. The actual element can be retrieved via the {@link GraphStageLogic.grab()} method.
        Throws:
        java.lang.Exception
      • onUpstreamFailure

        void onUpstreamFailure​(java.lang.Throwable ex)
                        throws java.lang.Exception
        Called when the input port has failed. After this callback no other callbacks will be called for this port.
        Parameters:
        ex - (undocumented)
        Throws:
        java.lang.Exception
      • onUpstreamFinish

        void onUpstreamFinish()
                       throws java.lang.Exception
        Called when the input port is finished. After this callback no other callbacks will be called for this port.
        Throws:
        java.lang.Exception