OverflowStrategy

java.lang.Object
- org.apache.pekko.stream.DelayOverflowStrategy
- - org.apache.pekko.stream.OverflowStrategy

All Implemented Interfaces:

java.io.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

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods
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`	`dropNew()`	Deprecated. Use `pekko.stream.javadsl.Source#queue(int,org.apache.pekko.stream.OverflowStrategy)` instead
`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 Detail
  - OverflowStrategy
```
public OverflowStrategy()
```
- Method Detail
  - 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.
  - dropNew
```
public static 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 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)
```