netutils/mqtt
1
0
Fork 0
mirror of https://github.com/go-mqtt/mqtt.git synced 2025-08-07 11:42:52 +03:00
Code Activity

Missed some with the last commit.

Browse Source
This commit is contained in:
Pascal S. de Kloe
2021-02-03 21:32:19 +01:00
parent b36ae7316e
commit 917669d69f
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/mqttc/main.go
View File

@@ -168,7 +168,7 @@ func main() {
switch { switch {
case err == nil, errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown): case err == nil, errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown):
return // OK return // OK
case errors.Is(err, mqtt.ErrAbort): case errors.Is(err, mqtt.ErrAbandon):
log.Fatal(name, ": subscribe timeout") log.Fatal(name, ": subscribe timeout")
fallthrough fallthrough
@@ -189,7 +189,7 @@ func main() {
break // OK break // OK
case errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown): case errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown):
return return
case errors.Is(err, mqtt.ErrAbort): case errors.Is(err, mqtt.ErrAbandon):
log.Print(name, ": ping timeout") log.Print(name, ": ping timeout")
fallthrough fallthrough

2
request_test.go
View File

@@ -162,7 +162,7 @@ func TestSubscribe(t *testing.T) {
2, // max QOS 2, // max QOS
})) }))
sendPacketHex(t, conn, "900440000102") // SUBACK sendPacketHex(t, conn, "900460000102") // SUBACK
} }
func TestPublish(t *testing.T) { func TestPublish(t *testing.T) {