From 917669d69f873a0a1caceb4a3ec6ab9b7d3a231c Mon Sep 17 00:00:00 2001 From: "Pascal S. de Kloe" Date: Wed, 3 Feb 2021 21:32:19 +0100 Subject: [PATCH] Missed some with the last commit. --- cmd/mqttc/main.go | 4 ++-- request_test.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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) {