Class GraphStageLogic.IgnoreTerminateInput$

  • All Implemented Interfaces:
    InHandler
    Enclosing class:
    GraphStageLogic

    public static class GraphStageLogic.IgnoreTerminateInput$
    extends java.lang.Object
    implements InHandler
    Input handler that does not terminate the operator upon receiving completion. The operator fails upon receiving a failure.
    • Constructor Detail

      • IgnoreTerminateInput$

        public IgnoreTerminateInput$()
    • Method Detail

      • onPush

        public void onPush()
        Description copied from interface: InHandler
        Called when the input port has a new element available. The actual element can be retrieved via the GraphStageLogic.grab method.
        Specified by:
        onPush in interface InHandler
      • onUpstreamFinish

        public void onUpstreamFinish()
        Description copied from interface: InHandler
        Called when the input port is finished. After this callback no other callbacks will be called for this port.
        Specified by:
        onUpstreamFinish in interface InHandler
      • toString

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