public class DelayOverflowStrategy$
extends java.lang.Object
implements scala.Serializable
Modifier and Type | Field and Description |
---|---|
static DelayOverflowStrategy$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
DelayOverflowStrategy$() |
Modifier and Type | Method and Description |
---|---|
DelayOverflowStrategy |
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.
|
DelayOverflowStrategy |
dropBuffer()
If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.
|
DelayOverflowStrategy |
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.
|
DelayOverflowStrategy |
dropNew()
If the buffer is full when a new element arrives, drops the new element.
|
DelayOverflowStrategy |
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.
|
DelayOverflowStrategy |
emitEarly()
If the buffer is full when a new element is available this strategy send next element downstream without waiting
|
DelayOverflowStrategy |
fail()
If the buffer is full when a new element is available this strategy completes the stream with failure.
|
public static final DelayOverflowStrategy$ MODULE$
public DelayOverflowStrategy emitEarly()
public DelayOverflowStrategy dropHead()
public DelayOverflowStrategy dropTail()
public DelayOverflowStrategy dropBuffer()
public DelayOverflowStrategy dropNew()
public DelayOverflowStrategy backpressure()
public DelayOverflowStrategy fail()