iter

package

v0.0.0-rc8 Latest Latest Go to latest Published: Nov 7, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func Map[T any, R any](iter Iter[T], mapper func(t T) (R, error)) ([]R, error)

func ToSlice[T any](iter Iter[T]) ([]T, error)

type BlobIter struct {
	// contains filtered or unexported fields
}

func FromReadCloser(r io.ReadCloser) *BlobIter

FromReadCloser returns an iterator producing lines from the given reader.

func (it *BlobIter) Close() error

func (it *BlobIter) Next() bool

func (it *BlobIter) Value() (string, error)

Value implements Iterator[T].Value by returning the next line from the reader.

type Iter[T any] interface {
	Next() bool
	Value() (T, error)
	Close() error
}

func FromSlice[T any](items ...T) Iter[T]

type MapIter[T any, R any] struct {
	It     Iter[T]
	Mapper func(t T) (R, error)
}

func (d *MapIter[T, R]) Close() error

func (d *MapIter[T, R]) Next() bool

func (d *MapIter[T, R]) Value() (R, error)