internal

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

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

type GeneratorIterator[T any] struct {
	Operation func(context.Context) (T, error)
	Closer    context.CancelFunc
	Error     error
	// contains filtered or unexported fields
}

type MergedError struct {
	Current error
	Wrapped error
}

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

type SyncIterImpl[T any] struct {
	Mtx  *sync.Mutex
	Iter interface {
		Next(context.Context) bool
		Value() T
		Close() error
	}
}