Package org.apache.pekko.stream.stage

Class GraphStageLogic.ConditionalTerminateOutput

  • All Implemented Interfaces:
    OutHandler
    Enclosing class:
    GraphStageLogic
    public static class GraphStageLogic.ConditionalTerminateOutput
extends java.lang.Object
implements OutHandler
    Output 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
      ConditionalTerminateOutput​(scala.Function0<java.lang.Object> predicate)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void onDownstreamFinish​(java.lang.Throwable cause)
      Called when the output port will no longer accept any new elements.
      void onPull()
      Called when the output port has received a pull, and therefore ready to emit an element, i.e.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • ConditionalTerminateOutput

        public ConditionalTerminateOutput​(scala.Function0<java.lang.Object> predicate)

    • Method Detail

      • onDownstreamFinish

        public void onDownstreamFinish​(java.lang.Throwable cause)
        Description copied from interface: OutHandler
        Called when the output port will no longer accept any new elements. After this callback no other callbacks will be called for this port.
        Specified by:
        onDownstreamFinish in interface OutHandler

      • 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