BufferOverflow

A strategy for buffer overflow handling in channels and flows that controls what is going to be sacrificed on buffer overflow:

  • SUSPEND — the upstream that is sending or is emitting a value is suspended while the buffer is full.

  • DROP_OLDEST — drop the oldest value in the buffer on overflow, add the new value to the buffer, do not suspend.

  • DROP_LATEST — drop the latest value that is being added to the buffer right now on buffer overflow (so that buffer contents stay the same), do not suspend.

Entries

Link copied to clipboard

Suspend on buffer overflow.

Link copied to clipboard

Drop the oldest value in the buffer on overflow, add the new value to the buffer, do not suspend.

Link copied to clipboard

Drop the latest value that is being added to the buffer right now on buffer overflow (so that buffer contents stay the same), do not suspend.

Properties

Link copied to clipboard
val entries: EnumEntries<BufferOverflow>

Returns a representation of an immutable list of all enum entries, in the order they're declared.

Functions

Link copied to clipboard

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Link copied to clipboard

Returns an array containing the constants of this enum type, in the order they're declared.