scheduler

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

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

type Handler[T any] func(context.Context, T)

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

type Options[T any] struct {
	Context     context.Context
	Handler     Handler[T]
	Parallelism int
}

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

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

type TaskSource[T any] interface {
	Next(ctx context.Context) (T, bool)
}