Method Encode

protocol/message_set.go:10–20

(e PacketEncoder)

}

func (ms *MessageSet) Encode(e PacketEncoder) error {
	e.PutInt64(ms.Offset)
	e.Push(&SizeField{})
	for _, m := range ms.Messages {
		if err := m.Encode(e); err != nil {
			return err
		}
	}
	e.Pop()
	return nil
}

func (ms *MessageSet) Decode(d PacketDecoder) error {
	var err error