OverflowStrategy

java.lang.Object

org.apache.pekko.stream.DelayOverflowStrategy

org.apache.pekko.stream.OverflowStrategy

All Implemented Interfaces:: Serializable

public abstract class OverflowStrategy extends DelayOverflowStrategy

Represents a strategy that decides how to deal with a buffer that is full but is about to receive a new element.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor

Description

OverflowStrategy()
Method Summary

Modifier and Type

Method

Description

static 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.

static OverflowStrategy

dropBuffer()

If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.

static 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.

static 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.

static OverflowStrategy

fail()

If the buffer is full when a new element is available this strategy completes the stream with failure.

abstract OverflowStrategy

withLogLevel(Logging.LogLevel logLevel)

Methods inherited from class org.apache.pekko.stream.DelayOverflowStrategy
emitEarly

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- OverflowStrategy
  
  public OverflowStrategy()
Method Details
- dropHead
  
  public static 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 static 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 static OverflowStrategy dropBuffer()
  
  If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.
- backpressure
  
  public static 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 static OverflowStrategy fail()
  
  If the buffer is full when a new element is available this strategy completes the stream with failure.
- withLogLevel
  
  public abstract OverflowStrategy withLogLevel(Logging.LogLevel logLevel)