zio

type Peeker ¶

type Peeker struct {
	Reader
	// contains filtered or unexported fields
}

Peeker wraps a Stream while adding a Peek method, which allows inspection of the next item to be read without actually reading it.

func NewPeeker(reader Reader) *Peeker

func (p *Peeker) Peek() (*zed.Value, error)

func (p *Peeker) Read() (*zed.Value, error)

type ReadCloser ¶

type ReadCloser interface {
	Reader
	io.Closer
}

func NewReadCloser(r Reader, c io.Closer) ReadCloser

func NopReadCloser(r Reader) ReadCloser

type Reader ¶

type Reader interface {
	Read() (val *zed.Value, err error)
}

Reader wraps the Read method.

Read returns the next value and a nil error, a nil value and the next error, or a nil value and nil error to indicate that no values remain.

Read never returns a non-nil value and non-nil error together, and it never returns io.EOF.

Implementations retain ownership of val and val.Bytes, and a subsequent Read may overwrite them. Clients that wish to use val or val.Bytes after the next Read must make a copy.

func ConcatReader(readers ...Reader) Reader

type WriteCloser ¶

type WriteCloser interface {
	Writer
	io.Closer
}

type Writer ¶

type Writer interface {
	Write(val zed.Value) error
}

Writer wraps the Write method.

Implementations must not retain val or val.Bytes.

func MultiWriter(writers ...Writer) Writer