Check and return a missed error.

huin · Aug 20, 2013 · 133aa78 · 133aa78
1 parent b6490bb
commit 133aa78
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/mqtt.go b/mqtt.go
@@ -153,6 +153,9 @@ func DecodeOneMessage(r io.Reader, config DecoderConfig) (msg Message, err error
 	var msgType MessageType
 	var packetRemaining int32
 	msgType, packetRemaining, err = hdr.Decode(r)
+	if err != nil {
+		return
+	}
 
 	msg, err = NewMessage(msgType)
 	if err != nil {