diff --git a/loop.go b/loop.go index be271b8..ba3691d 100644 --- a/loop.go +++ b/loop.go @@ -110,6 +110,7 @@ func inLoop(c *Channel, m *methods) error { msg, err := protocol.Decode(pkg) if err != nil { CloseChannel(c, m, protocol.ErrorWrongPacket) + return err } switch msg.Type {