Package org.apache.pekko.stream
Class OverflowStrategy$
- java.lang.Object
- 
- org.apache.pekko.stream.OverflowStrategy$
 
- 
- All Implemented Interfaces:
- java.io.Serializable
 
 public class OverflowStrategy$ extends java.lang.Object implements java.io.Serializable- See Also:
- Serialized Form
 
- 
- 
Field SummaryFields Modifier and Type Field Description static OverflowStrategy$MODULE$Static reference to the singleton instance of this Scala object.
 - 
Constructor SummaryConstructors Constructor Description OverflowStrategy$()
 - 
Method SummaryAll 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.Usepekko.stream.javadsl.Source#queue(int,org.apache.pekko.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- 
dropHeadpublic 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 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 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 OverflowStrategy dropNew() Deprecated.Usepekko.stream.javadsl.Source#queue(int,org.apache.pekko.stream.OverflowStrategy)insteadIf the buffer is full when a new element arrives, drops the new element.
 - 
backpressurepublic 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 OverflowStrategy fail() If the buffer is full when a new element is available this strategy completes the stream with failure.
 
- 
 
-