diff --git a/src/lib/client.ts b/src/lib/client.ts index f7a9b4dcc..2378e0fd6 100644 --- a/src/lib/client.ts +++ b/src/lib/client.ts @@ -850,6 +850,7 @@ export default class MqttClient extends TypedEventEmitter { + assert.equal(err.message, 'connack timeout') + client.end(true, done) + }) + }) + it( 'should resend in-flight QoS 1 publish messages from the client', {