Class GraphStageLogic.EagerTerminateOutput$

  • All Implemented Interfaces:
    OutHandler
    Enclosing class:
    GraphStageLogic

    public static class GraphStageLogic.EagerTerminateOutput$
    extends java.lang.Object
    implements OutHandler
    Output handler that terminates the operator upon cancellation.
    • Constructor Detail

      • EagerTerminateOutput$

        public EagerTerminateOutput$()
    • 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
      • toString

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