akka.stream

Class DelayOverflowStrategy

java.lang.Object

akka.stream.DelayOverflowStrategy

All Implemented Interfaces:

java.io.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 stage that is full but is about to receive a new element.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DelayOverflowStrategy()

Method Summary

Modifier and Type	Method and 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	dropNew() If the buffer is full when a new element arrives, drops 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
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 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)