Class GraphStageLogic.ConditionalTerminateInput

  • All Implemented Interfaces:
    InHandler
    Enclosing class:
    GraphStageLogic

    public static class GraphStageLogic.ConditionalTerminateInput
    extends java.lang.Object
    implements InHandler
    • 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