diff --git a/message_set.go b/message_set.go index 3895ab6a5..27db52fdf 100644 --- a/message_set.go +++ b/message_set.go @@ -66,6 +66,10 @@ func (ms *MessageSet) decode(pd packetDecoder) (err error) { for pd.remaining() > 0 { magic, err := magicValue(pd) if err != nil { + if err == ErrInsufficientData { + ms.PartialTrailingMessage = true + return nil + } return err }