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()
      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. {@link GraphStageLogic.push()} is now allowed to be called on this port.
        Specified by:
        onPull in interface OutHandler
      • onDownstreamFinish

        public void onDownstreamFinish()
        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