rawmessage

May 16, 2023

Changes in this version

+ type Message struct

+ Body []byte

+ ChunkStreamID byte

+ MessageStreamID uint32

+ Timestamp time.Duration

+ Type uint8

+ type Reader struct

+ func NewReader(r *bytecounter.Reader, onAckNeeded func(uint32) error) *Reader

+ func (r *Reader) Read() (*Message, error)

+ func (r *Reader) SetChunkSize(v uint32)

+ func (r *Reader) SetWindowAckSize(v uint32)

+ type Writer struct

+ func NewWriter(w *bytecounter.Writer, checkAcknowledge bool) *Writer

+ func (w *Writer) SetAcknowledgeValue(v uint32)

+ func (w *Writer) SetChunkSize(v uint32)

+ func (w *Writer) SetWindowAckSize(v uint32)

+ func (w *Writer) Write(msg *Message) error