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 Summary
Constructors Constructor Description OverflowStrategy() 
- 
Method Summary
All 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.DelayOverflowStrategy
emitEarly 
 - 
 
 - 
 
- 
- 
Method Detail
- 
dropHead
public 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. 
- 
dropTail
public 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. 
- 
dropBuffer
public 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. 
- 
dropNew
public static OverflowStrategy dropNew()
Deprecated.UseSource.queue(int,akka.stream.OverflowStrategy)insteadIf the buffer is full when a new element arrives, drops the new element. 
- 
backpressure
public 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. 
- 
fail
public static OverflowStrategy fail()
If the buffer is full when a new element is available this strategy completes the stream with failure. 
- 
withLogLevel
public abstract OverflowStrategy withLogLevel(Logging.LogLevel logLevel)
 
 - 
 
 -