Class GraphStageLogic.ConditionalTerminateInput

  • All Implemented Interfaces:
    InHandler
    Enclosing class:
    GraphStageLogic

    public static class GraphStageLogic.ConditionalTerminateInput
    extends java.lang.Object
    implements InHandler
    Input handler that terminates the state upon receiving completion if the given condition holds at that time. The operator fails upon receiving a failure.
    • Constructor Summary

      Constructors 
      Constructor Description
      ConditionalTerminateInput​(scala.Function0<java.lang.Object> predicate)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void onPush()
      Called when the input port has a new element available.
      void onUpstreamFinish()
      Called when the input port is finished.
      • Methods inherited from class java.lang.Object

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

      • ConditionalTerminateInput

        public ConditionalTerminateInput​(scala.Function0<java.lang.Object> predicate)
    • 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