Add MqttClientIsConnected()

2 files changed, 7 insertions, 0 deletions

diff --git a/src/client.c b/src/client.c
index c9fa876..4d796a9 100644
--- a/src/client.c
+++ b/src/client.c
@@ -282,6 +282,11 @@ int MqttClientDisconnect(MqttClient *client)
     return MqttClientQueueSimplePacket(client, MqttPacketTypeDisconnect);
 }
 
+int MqttClientIsConnected(MqttClient *client)
+{
+    return client->stream.sock != -1;
+}
+
 int MqttClientRunOnce(MqttClient *client, int timeout)
 {
     int rv;
diff --git a/src/mqtt.h b/src/mqtt.h
index 4ea0930..f07ff3c 100644
--- a/src/mqtt.h
+++ b/src/mqtt.h
@@ -73,6 +73,8 @@ int MqttClientConnect(MqttClient *client, const char *host, short port,
 
 int MqttClientDisconnect(MqttClient *client);
 
+int MqttClientIsConnected(MqttClient *client);
+
 int MqttClientRunOnce(MqttClient *client, int timeout);
 
 int MqttClientRun(MqttClient *client);