Package akka.stream

Class DelayOverflowStrategy

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

    public abstract class DelayOverflowStrategy
    extends java.lang.Object
    implements scala.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
    • 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
        Returns:
        (undocumented)
      • 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.
        Returns:
        (undocumented)
      • 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.
        Returns:
        (undocumented)
      • 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.
        Returns:
        (undocumented)
      • dropNew

        public static DelayOverflowStrategy dropNew()
        If the buffer is full when a new element arrives, drops the new element.
        Returns:
        (undocumented)
      • 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.
        Returns:
        (undocumented)
      • fail

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

        public abstract boolean isBackpressure()
        INTERNAL API