type ReadCloser interface {
Reader
io.Closer
}
func NewDelimitedReader(r io.Reader, maxSize int) ReadCloser
func NewFullReader(r io.Reader, maxSize int) ReadCloser
func NewUint32DelimitedReader(r io.Reader, byteOrder binary.ByteOrder, maxSize int) ReadCloser
type Reader interface {
ReadMsg(msg proto.Message) error
}
type WriteCloser interface {
Writer
io.Closer
}
func NewDelimitedWriter(w io.Writer) WriteCloser
func NewFullWriter(w io.Writer) WriteCloser
func NewSizeUint32DelimitedWriter(w io.Writer, byteOrder binary.ByteOrder, size int) WriteCloser
func NewUint32DelimitedWriter(w io.Writer, byteOrder binary.ByteOrder) WriteCloser
type Writer interface {
WriteMsg(proto.Message) error
}