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 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.OverflowStrategydropBuffer()If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.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.OverflowStrategydropNew()Deprecated.UseSource.queue(int,akka.stream.OverflowStrategy)insteadOverflowStrategydropTail()If the buffer is full when a new element arrives, drops the youngest element from the buffer to make space for the new element.OverflowStrategyfail()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. 
 - 
 
 -