Package akka.stream
Class OverflowStrategy$
- java.lang.Object
-
- akka.stream.OverflowStrategy$
-
- All Implemented Interfaces:
java.io.Serializable
public class OverflowStrategy$ extends java.lang.Object implements java.io.Serializable
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static OverflowStrategy$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description OverflowStrategy$()
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description 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.OverflowStrategy
dropBuffer()
If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.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.OverflowStrategy
dropNew()
Deprecated.UseSource.queue(int,akka.stream.OverflowStrategy)
insteadOverflowStrategy
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.OverflowStrategy
fail()
If the buffer is full when a new element is available this strategy completes the stream with failure.
-
-
-
Field Detail
-
MODULE$
public static final OverflowStrategy$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
dropHead
public 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 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 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 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 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 OverflowStrategy fail()
If the buffer is full when a new element is available this strategy completes the stream with failure.
-
-