diff --git a/src/PubSubClient.cpp b/src/PubSubClient.cpp index f60d6a0..836484c 100755 --- a/src/PubSubClient.cpp +++ b/src/PubSubClient.cpp @@ -561,6 +561,7 @@ void PubSubClient::disconnect() { buffer[1] = 0; _client->write(buffer,2); _state = MQTT_DISCONNECTED; + _client->flush(); _client->stop(); lastInActivity = lastOutActivity = millis(); }