accumulator

type Accumulator[T any] struct {
	// The queue for the items.
	Queue stack.Stack[T]

	// The number of items to accumulate before the queue is flushed.
	FlushSize int

	// The time to wait before flushing the queue.
	FlushInterval time.Duration

	// Reset the flush interval after a push.
	ResetAfterPush bool

	// The function which is called when the queue is flushed.
	FlushFunc func([]T)
	// contains filtered or unexported fields
}