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 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.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.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.static OverflowStrategy
dropNew()
Deprecated.UseSource.queue(int,akka.stream.OverflowStrategy)
insteadstatic 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.static OverflowStrategy
fail()
If the buffer is full when a new element is available this strategy completes the stream with failure.abstract OverflowStrategy
withLogLevel(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)
-
-