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.

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

constructor(capacity: Int, onBufferOverflow: BufferOverflow = BufferOverflow.DROP_OLDEST)

override val name: String

suspend override fun append(event: T)

abstract suspend fun handle(event: T)

open override fun setup(flow: Flow<T>): Flow<T>