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.SerializableRepresents 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 DelayOverflowStrategybackpressure()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 DelayOverflowStrategydropBuffer()If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.static DelayOverflowStrategydropHead()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 DelayOverflowStrategydropNew()If the buffer is full when a new element arrives, drops the new element.static DelayOverflowStrategydropTail()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 DelayOverflowStrategyemitEarly()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 DelayOverflowStrategyfail()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. 
 - 
 
 -