delimited

Documentation

Overview

Package delimited allows for reading of a stream of protobuf messages delimited by size. See https://developers.google.com/protocol-buffers/docs/techniques#streaming for more info.

Index

• type Reader
  • func NewReader(r io.Reader) *Reader
  • func (r *Reader) Next() ([]byte, error)

Types

type Reader

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

Reader wraps an io.Reader and exposes methods to iterate on individual messages.

func NewReader

func NewReader(r io.Reader) *Reader

NewReader returns a Reader that reads bytes from the supplied Reader.

func (*Reader) Next

func (r *Reader) Next() ([]byte, error)

Next returns a byte slice with the next message, or an error: * io.EOF if there are no messages remaining * io.ErrUnexpectedEOF if the stream is corrupted