Class OverflowStrategy$

  • All Implemented Interfaces:
    java.io.Serializable

    public class OverflowStrategy$
    extends java.lang.Object
    implements java.io.Serializable
    See Also:
    Serialized Form
    • Field Summary

      Fields 
      Modifier and Type Field Description
      static OverflowStrategy$ MODULE$
      Static reference to the singleton instance of this Scala object.
    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      OverflowStrategy 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.
      OverflowStrategy dropBuffer()
      If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.
      OverflowStrategy 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.
      OverflowStrategy dropNew()
      Deprecated.
      Use pekko.stream.javadsl.Source#queue(int,org.apache.pekko.stream.OverflowStrategy) instead
      OverflowStrategy 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.
      OverflowStrategy fail()
      If the buffer is full when a new element is available this strategy completes the stream with failure.
      • Methods inherited from class java.lang.Object

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

      • MODULE$

        public static final OverflowStrategy$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • OverflowStrategy$

        public OverflowStrategy$()
    • Method Detail

      • dropHead

        public OverflowStrategy 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 OverflowStrategy 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 OverflowStrategy 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 OverflowStrategy dropNew()
        Deprecated.
        Use pekko.stream.javadsl.Source#queue(int,org.apache.pekko.stream.OverflowStrategy) instead
        If the buffer is full when a new element arrives, drops the new element.

      • backpressure

        public OverflowStrategy 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 OverflowStrategy fail()
        If the buffer is full when a new element is available this strategy completes the stream with failure.