Package 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 java.io.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
All Methods Static Methods Concrete Methods 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()
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.
-
-
-
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 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.
-
dropNew
public static DelayOverflowStrategy dropNew()
If the buffer is full when a new element arrives, drops 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.
-
-