internal

package

v0.3.3 Latest Latest Go to latest Published: Jan 29, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

	Error error
	// contains filtered or unexported fields
}

func (iter *ChannelIterImpl[T]) Close(_ context.Context) error

func (iter *ChannelIterImpl[T]) Next(ctx context.Context) bool

func (iter *ChannelIterImpl[T]) Value() T

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

func (iter *MapIterImpl[T]) Close(ctx context.Context) error

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

func (iter *SliceIterImpl[T]) Close(_ context.Context) error

func (iter *SliceIterImpl[T]) Next(ctx context.Context) bool

func (iter *SliceIterImpl[T]) Value() T