Class GraphStageLogic.IgnoreTerminateOutput$

  • All Implemented Interfaces:
    OutHandler
    Enclosing class:
    GraphStageLogic

    public static class GraphStageLogic.IgnoreTerminateOutput$
    extends java.lang.Object
    implements OutHandler
    Output handler that does not terminate the operator upon cancellation.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void onDownstreamFinish​(java.lang.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.
      java.lang.String toString()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • IgnoreTerminateOutput$

        public IgnoreTerminateOutput$()
    • Method Detail

      • onPull

        public void onPull()
        Description copied from interface: OutHandler
        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.
        Specified by:
        onPull in interface OutHandler
      • onDownstreamFinish

        public void onDownstreamFinish​(java.lang.Throwable cause)
        Description copied from interface: OutHandler
        Called when the output port will no longer accept any new elements. After this callback no other callbacks will be called for this port.
        Specified by:
        onDownstreamFinish in interface OutHandler
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object