loop

type Handler[T any] interface {
	Handle(ctx context.Context, t T) error
}

type Interface[T any] interface {
	Run(ctx context.Context) error
	Enqueue(t T)
	Close(t T)
	Reset(h Handler[T], size uint64) Interface[T]
}