Skip to content

Commit 70d3113

Browse files
authored
fix stuck connection
1 parent 7c2f4bb commit 70d3113

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/MqttClient.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -229,6 +229,9 @@ void MqttClient::loop() {
229229
_parser.reset();
230230
_lastClientActivity = _lastServerActivity = millis();
231231
_setState(State::connectingMqtt);
232+
} else if (_transport->disconnected()) { // sync: implemented as "not connected"; async: depending on state of pcb in underlying lib
233+
_setState(State::disconnectingTcp1);
234+
_disconnectReason = DisconnectReason::TCP_DISCONNECTED;
232235
}
233236
break;
234237
case State::connectingMqtt:

0 commit comments

Comments
 (0)