| DelayOverflowStrategy Enumeration |
Represents a strategy that decides how to deal with a buffer of time based stage that is full but is about to receive a new element.
Namespace:
Akka.Streams
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax public enum DelayOverflowStrategy
type DelayOverflowStrategy
Members
| Member name | Value | Description |
---|
| EmitEarly | 1 |
If the buffer is full when a new element is available this strategy send next element downstream without waiting
|
| DropHead | 2 |
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 | 3 |
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 | 4 |
If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element.
|
| DropNew | 5 |
If the buffer is full when a new element arrives, drops the new element.
|
| Backpressure | 6 |
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 | 7 |
If the buffer is full when a new element is available this strategy completes the stream with failure.
|
See Also