Versions in this module Expand all Collapse all v0 v0.1.0 Jul 13, 2023 Changes in this version + type ReadWriter struct + func New(rw io.ReadWriter) ReadWriter + type Reader struct + func NewReader(r io.Reader) *Reader + func (r *Reader) ReadMessage(m proto.Message) (err error) + func (r *Reader) ReadStream(chunkHandler func([]byte) error) (err error) + type Writer struct + func NewWriter(w io.Writer) *Writer + func (w *Writer) Flush() error + func (w *Writer) WriteMessage(m proto.Message) (err error) + func (w *Writer) WriteStream(filler func([]byte) (int, error)) (err error)