stream

Documentation

Index

• Constants
• Variables
• func NewProtoMessageReader(r io.Reader) protoio.ReadCloser
• func NewProtoMessageWriter(w io.Writer) protoio.WriteCloser

Constants

const MAX_MESSAGE_SIZE = 1024 * 1024

Variables

var ProtoByteOrder = binary.BigEndian

Functions

func NewProtoMessageReader

func NewProtoMessageReader(r io.Reader) protoio.ReadCloser

NewProtoMessageReader returns a new reader for reading proto messages.

func NewProtoMessageWriter

func NewProtoMessageWriter(w io.Writer) protoio.WriteCloser

NewProtoMessageWriter returns a new writer for writing proto messages.