Package akka.stream.stage

Class GraphStageLogic.ConditionalTerminateOutput

  • All Implemented Interfaces:
    OutHandler
    Enclosing class:
    GraphStageLogic
    public static class GraphStageLogic.ConditionalTerminateOutput
extends java.lang.Object
implements OutHandler

    • 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()
      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()
        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. {@link GraphStageLogic.push()} is now allowed to be called on this port.
        Specified by:
        onPull in interface OutHandler