loop

type Factory[T any] struct {
	// contains filtered or unexported fields
}

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)
}