Package akka.stream

Class DelayOverflowStrategy

  • All Implemented Interfaces:
    java.io.Serializable
    Direct Known Subclasses:
    OverflowStrategies.EmitEarly$, OverflowStrategy

    public abstract class DelayOverflowStrategy
    extends java.lang.Object
    implements java.io.Serializable
    Represents a strategy that decides how to deal with a buffer of time based operator that is full but is about to receive a new element.
    See Also:
    Serialized Form
    • Method Summary

      All Methods Static Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      static DelayOverflowStrategy backpressure()
      If the buffer is full when a new element is available this strategy backpressures the upstream publisher until space becomes available in the buffer.
      static DelayOverflowStrategy dropBuffer()
      If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.
      static DelayOverflowStrategy dropHead()
      If the buffer is full when a new element arrives, drops the oldest element from the buffer to make space for the new element.
      static DelayOverflowStrategy dropNew()
      If the buffer is full when a new element arrives, drops the new element.
      static DelayOverflowStrategy dropTail()
      If the buffer is full when a new element arrives, drops the youngest element from the buffer to make space for the new element.
      static DelayOverflowStrategy emitEarly()
      If the buffer is full when a new element is available this strategy send next element downstream without waiting Will backpressure if downstream is not ready.
      static DelayOverflowStrategy fail()
      If the buffer is full when a new element is available this strategy completes the stream with failure.
      abstract boolean isBackpressure()
      INTERNAL API
      • Methods inherited from class java.lang.Object

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

      • DelayOverflowStrategy

        public DelayOverflowStrategy()
    • Method Detail

      • emitEarly

        public static DelayOverflowStrategy emitEarly()
        If the buffer is full when a new element is available this strategy send next element downstream without waiting Will backpressure if downstream is not ready.
      • dropHead

        public static DelayOverflowStrategy dropHead()
        If the buffer is full when a new element arrives, drops the oldest element from the buffer to make space for the new element.
      • dropTail

        public static DelayOverflowStrategy dropTail()
        If the buffer is full when a new element arrives, drops the youngest element from the buffer to make space for the new element.
      • dropBuffer

        public static DelayOverflowStrategy dropBuffer()
        If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.
      • dropNew

        public static DelayOverflowStrategy dropNew()
        If the buffer is full when a new element arrives, drops the new element.
      • backpressure

        public static DelayOverflowStrategy backpressure()
        If the buffer is full when a new element is available this strategy backpressures the upstream publisher until space becomes available in the buffer.
      • fail

        public static DelayOverflowStrategy fail()
        If the buffer is full when a new element is available this strategy completes the stream with failure.
      • isBackpressure

        public abstract boolean isBackpressure()
        INTERNAL API