Package org.apache.pekko.stream

Class DelayOverflowStrategy

java.lang.Object

org.apache.pekko.stream.DelayOverflowStrategy

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

OverflowStrategies.EmitEarly$, OverflowStrategy

public abstract class DelayOverflowStrategy
extends Object
implements 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 Summary

Constructors

Constructor	Description
DelayOverflowStrategy()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DelayOverflowStrategy

public DelayOverflowStrategy()

Method Details

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.

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.