diff --git a/cmd/mqttc/main.go b/cmd/mqttc/main.go
index f151612..9876d62 100644
--- a/cmd/mqttc/main.go
+++ b/cmd/mqttc/main.go
@@ -168,7 +168,7 @@ func main() {
 			switch {
 			case err == nil, errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown):
 				return // OK
-			case errors.Is(err, mqtt.ErrAbort):
+			case errors.Is(err, mqtt.ErrAbandon):
 				log.Fatal(name, ": subscribe timeout")
 
 				fallthrough
@@ -189,7 +189,7 @@ func main() {
 				break // OK
 			case errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown):
 				return
-			case errors.Is(err, mqtt.ErrAbort):
+			case errors.Is(err, mqtt.ErrAbandon):
 				log.Print(name, ": ping timeout")
 
 				fallthrough
diff --git a/request_test.go b/request_test.go
index 7e4336a..2dd3821 100644
--- a/request_test.go
+++ b/request_test.go
@@ -162,7 +162,7 @@ func TestSubscribe(t *testing.T) {
 		2, // max QOS
 	}))
 
-	sendPacketHex(t, conn, "900440000102") // SUBACK
+	sendPacketHex(t, conn, "900460000102") // SUBACK
 }
 
 func TestPublish(t *testing.T) {