Package akka.stream
Class OverflowStrategy
- java.lang.Object
- 
- akka.stream.DelayOverflowStrategy
- 
- akka.stream.OverflowStrategy
 
 
- 
- All Implemented Interfaces:
- java.io.Serializable
 
 public abstract class OverflowStrategy extends DelayOverflowStrategy Represents a strategy that decides how to deal with a buffer that is full but is about to receive a new element.- See Also:
- Serialized Form
 
- 
- 
Constructor SummaryConstructors Constructor Description OverflowStrategy()
 - 
Method SummaryAll Methods Static Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static OverflowStrategybackpressure()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 OverflowStrategydropBuffer()If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.static OverflowStrategydropHead()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 OverflowStrategydropNew()Deprecated.UseSource.queue(int,akka.stream.OverflowStrategy)insteadstatic OverflowStrategydropTail()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 OverflowStrategyfail()If the buffer is full when a new element is available this strategy completes the stream with failure.abstract OverflowStrategywithLogLevel(Logging.LogLevel logLevel)- 
Methods inherited from class akka.stream.DelayOverflowStrategyemitEarly
 
- 
 
- 
- 
- 
Method Detail- 
dropHeadpublic static OverflowStrategy 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 OverflowStrategy 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 OverflowStrategy 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 OverflowStrategy dropNew() Deprecated.UseSource.queue(int,akka.stream.OverflowStrategy)insteadIf the buffer is full when a new element arrives, drops the new element.
 - 
backpressurepublic static OverflowStrategy 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 OverflowStrategy fail() If the buffer is full when a new element is available this strategy completes the stream with failure.
 - 
withLogLevelpublic abstract OverflowStrategy withLogLevel(Logging.LogLevel logLevel) 
 
- 
 
-