fix mqtt transport write

Author: tuanpmt

libraries/ESP8266MQTTClient/examples/MQTTOverWebsocketClient/MQTTOverWebsocketClient.ino

@@ -28,8 +28,8 @@ void setup() {
 //    mqtt.subscribe("/qos2", 2);
   });
 
-//  mqtt.begin("ws://test.mosquitto.org:8080");
-  mqtt.begin("mqtt://test.mosquitto.org:1883");
+  mqtt.begin("ws://test.mosquitto.org:8080");
+//  mqtt.begin("mqtt://test.mosquitto.org:1883");
 
 //  mqtt.begin("mqtt://test.mosquitto.org:1883", {.lwtTopic = "hello", .lwtMsg = "offline", .lwtQos = 0, .lwtRetain = 0});
 //  mqtt.begin("mqtt://user:[email protected]:1883");

libraries/ESP8266MQTTClient/src/ESP8266MQTTClient.cpp

@@ -207,7 +207,7 @@ bool MQTTClient::connect(void)
     while(!_tcp->available()) {
         if(!_tcp->connected())
             return false;
-        delay(10);
+        yield();
         if(millis() - connect_tick > MQTT_CONNECT_TIMEOUT){
             _tcp->stop();
             return false;

libraries/ESP8266MQTTClient/src/ESP8266MQTTClient.h

@@ -48,7 +48,7 @@ License (MIT license):
 #define DEFAULT_MQTT_BUFFER_SIZE_BYTES	1024
 #define DEFAULT_MQTT_CLEAN_SESSION 1
 #define MQTT_RECONNECT_TIMEOUT 5000
-#define MQTT_CONNECT_TIMEOUT 5000
+#define MQTT_CONNECT_TIMEOUT 10000
 #define DEFAULT_MQTT_READ_TIMEOUT 200
 #define DEFAULT_MQTT_MAX_QUEUE (1024*8)
 typedef struct {

libraries/ESP8266MQTTClient/src/MQTTTransport.cpp

@@ -26,7 +26,7 @@ bool MQTTTransportTraits::connect(WiFiClient& client, const char* host, int port
 }
 int MQTTTransportTraits::write(WiFiClient& client, unsigned char *data, int size)
 {
-	return client.connect(data, size);
+	return client.write(data, size);
 }
 int MQTTTransportTraits::read(WiFiClient& client, unsigned char *data, int size)
 {