Package akka.stream

Class DelayOverflowStrategy

java.lang.Object

akka.stream.DelayOverflowStrategy

All Implemented Interfaces:

java.io.Serializable, scala.Serializable

Direct Known Subclasses:

OverflowStrategies.EmitEarly$, OverflowStrategy

public abstract class DelayOverflowStrategy
extends java.lang.Object
implements scala.Serializable

INTERNAL API

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

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()

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)

isBackpressure

public abstract boolean isBackpressure()