@@ -448,17 +448,17 @@ void MqttClient::poll()
448448 if ((b & 0x80 ) == 0 ) { // length done
449449 bool malformedResponse = false ;
450450
451- if (_rxType == MQTT_CONNACK ||
451+ if (_rxType == MQTT_CONNACK ||
452452 _rxType == MQTT_PUBACK ||
453- _rxType == MQTT_PUBREC ||
453+ _rxType == MQTT_PUBREC ||
454454 _rxType == MQTT_PUBCOMP ||
455455 _rxType == MQTT_UNSUBACK) {
456456 malformedResponse = (_rxFlags != 0x00 || _rxLength != 2 );
457457 } else if (_rxType == MQTT_PUBLISH) {
458458 malformedResponse = ((_rxFlags & 0x06 ) == 0x06 );
459459 } else if (_rxType == MQTT_PUBREL) {
460460 malformedResponse = (_rxFlags != 0x02 || _rxLength != 2 );
461- } else if (_rxType == MQTT_SUBACK) {
461+ } else if (_rxType == MQTT_SUBACK) {
462462 malformedResponse = (_rxFlags != 0x00 || _rxLength != 3 );
463463 } else if (_rxType == MQTT_PINGRESP) {
464464 malformedResponse = (_rxFlags != 0x00 || _rxLength != 0 );
@@ -531,7 +531,7 @@ void MqttClient::poll()
531531 if (_rxMessageIndex == 2 ) {
532532 _rxMessageTopicLength = (_rxMessageBuffer[0 ] << 8 ) | _rxMessageBuffer[1 ];
533533 _rxLength -= 2 ;
534-
534+
535535 _rxMessageTopic = " " ;
536536 _rxMessageTopic.reserve (_rxMessageTopicLength);
537537
@@ -722,7 +722,7 @@ int MqttClient::read(uint8_t *buf, size_t size)
722722
723723 if (b == -1 ) {
724724 break ;
725- }
725+ }
726726
727727 result++;
728728 *buf++ = b;
@@ -819,7 +819,7 @@ void MqttClient::setTxPayloadSize(unsigned short size)
819819 _txPayloadBuffer = NULL ;
820820 _txPayloadBufferIndex = 0 ;
821821 }
822-
822+
823823 _tx_payload_buffer_size = size;
824824}
825825
0 commit comments