buffer

Dec 12, 2024

Changes in this version

+ type Buffer struct

+ func NewBuffer[T any](bufferSize int, consumer BufferedConsumer[T]) *Buffer[T]

+ func (b *Buffer[T]) Append(ctx context.Context, item T) error

+ func (b *Buffer[T]) Flush(ctx context.Context) error

+ type BufferedConsumer func(ctx context.Context, buffer []T) error