Class GraphStageLogic.EagerTerminateInput$

  • All Implemented Interfaces:
    InHandler
    Enclosing class:
    GraphStageLogic

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

      • EagerTerminateInput$

        public EagerTerminateInput$()
    • 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 {@link GraphStageLogic.grab()} method.
        Specified by:
        onPush in interface InHandler
      • toString

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