public abstract class OverflowStrategy extends DelayOverflowStrategy
Constructor and Description |
---|
OverflowStrategy() |
Modifier and Type | Method and 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()
If the buffer is full when a new element arrives, drops the new element.
|
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.
|
static OverflowStrategy |
fail()
If the buffer is full when a new element is available this strategy completes the stream with failure.
|
emitEarly
public static OverflowStrategy dropHead()
public static OverflowStrategy dropTail()
public static OverflowStrategy dropBuffer()
public static OverflowStrategy dropNew()
public static OverflowStrategy backpressure()
public static OverflowStrategy fail()