stream

type Iterator ¶

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

func Iter[T any](r Reader[T]) *Iterator[T]

func (it *Iterator[T]) Err() error

func (it *Iterator[T]) Next() bool

func (it *Iterator[T]) Reset(r Reader[T])

func (it *Iterator[T]) Value() T

type Optional ¶

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

func Opt[T any](val T, err error) Optional[T]

func (opt Optional[T]) Value() (T, error)

type ReadCloser ¶

type ReadCloser[T any] interface {
	Reader[T]
	io.Closer
}

ReadCloser represents a closable stream of values of T.

ReadClosers is like io.ReadCloser for values of any type.

func ErrCloser[T any](err error) ReadCloser[T]

func NewReadCloser[T any](r Reader[T], c io.Closer) ReadCloser[T]

func NopCloser[T any](r Reader[T]) ReadCloser[T]

type ReadSeekCloser ¶

type ReadSeekCloser[T any] interface {
	Reader[T]
	io.Seeker
	io.Closer
}

type ReadSeeker ¶

type ReadSeeker[T any] interface {
	Reader[T]
	io.Seeker
}

type Reader ¶

type Reader[T any] interface {
	// Reads values from the stream, returning the number of values read and any
	// error that occurred.
	//
	// The error is io.EOF when the end of the stream has been reached.
	Read(values []T) (int, error)
}

Reader is an interface implemented by types that read a stream of values of type T.

func ChanReader[T any](ch <-chan Optional[T]) Reader[T]

func ConvertReader[To, From any](base Reader[From], conv func(From) (To, error)) Reader[To]

func MultiReader[T any](readers ...Reader[T]) Reader[T]

func NewReader[T any](values ...T) Reader[T]

func ReaderFunc[T any](f func([]T) (int, error)) Reader[T]

type WriteCloser ¶

type WriteCloser[T any] interface {
	Writer[T]
	io.Closer
}

WriteCloser represents a closable stream of values of T.

WriteClosers is like io.WriteCloser for values of any type.

func NewWriteCloser[T any](w Writer[T], c io.Closer) WriteCloser[T]

type Writer ¶

type Writer[T any] interface {
	Write(values []T) (int, error)
}

Writer is an interface implemented by types that write a stream of values of type T.

func ConvertWriter[To, From any](base Writer[To], conv func(From) (To, error)) Writer[From]