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 SummaryConstructors Constructor Description DelayOverflowStrategy()
 - 
Method SummaryAll 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- 
emitEarlypublic 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.
 - 
dropHeadpublic 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.
 - 
dropTailpublic 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.
 - 
dropBufferpublic 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.
 - 
dropNewpublic static DelayOverflowStrategy dropNew() If the buffer is full when a new element arrives, drops the new element.
 - 
backpressurepublic 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.
 - 
failpublic static DelayOverflowStrategy fail() If the buffer is full when a new element is available this strategy completes the stream with failure.
 
- 
 
-