FlowBufferedAppender

abstract class FlowBufferedAppender<T>(capacity: Int, onBufferOverflow: BufferOverflow = BufferOverflow.DROP_OLDEST) : FlowAppender<T, T>

FlowBufferedAppender is an abstract class that extends FlowAppender to provide buffering capabilities for processing events using Kotlin Flows.

Parameters

T

The type of the events to be processed.

capacity

The maximum size of the buffer.

onBufferOverflow

Specifies the behavior when the buffer overflows. Defaults to BufferOverflow.DROP_OLDEST.

Constructors

Link copied to clipboard
constructor(capacity: Int, onBufferOverflow: BufferOverflow = BufferOverflow.DROP_OLDEST)

Properties

Link copied to clipboard
override val name: String

Functions

Link copied to clipboard
suspend override fun append(event: T)
Link copied to clipboard
abstract suspend fun handle(event: T)
Link copied to clipboard
open override fun setup(flow: Flow<T>): Flow<T>