internal

type ChannelIterImpl[T any] struct {
	Pipe <-chan T

	Error  error
	Ctx    context.Context
	Closer context.CancelFunc
	// contains filtered or unexported fields
}

type MapIterImpl[T any] struct {
	ChannelIterImpl[T]
	WG sync.WaitGroup
}

type SliceIterImpl[T any] struct {
	Vals  []T
	Index int
	// contains filtered or unexported fields
}