Enum DelayOverflowStrategy
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.dll
Syntax
public enum DelayOverflowStrategyFields
| Name | Description |
|---|---|
| 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. |
| DropBuffer | If the buffer is full when a new element arrives, drops all the buffered elements to make space for the new element. |
| 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. |
| DropNew | If the buffer is full when a new element arrives, drops the new element. |
| 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. |
| EmitEarly | If the buffer is full when a new element is available this strategy send next element downstream without waiting |
| Fail | If the buffer is full when a new element is available this strategy completes the stream with failure. |
Edit this page