 
         let publishBytes: [UInt8] = [
             0x30] +                             // FIXED BYTE 1   3 = PUBLISH, 0 = DUP QoS RETAIN
-
-        remainingLengthBytes +                  // remaining length, variable
-
-        [UInt16(topic.utf8.count).highByte,     // topic length MSB
+            remainingLengthBytes +              // remaining length, variable
+            [UInt16(topic.utf8.count).highByte, // topic length MSB
             UInt16(topic.utf8.count).lowByte    // topic length LSB
         ]
-        
+
         let messageBytes = publishBytes + [UInt8](topic.utf8) + [UInt8](message)
         outputStream?.write(messageBytes, maxLength: messageBytes.count)
     }
-    
+
     @objc private func mqttPing(outputStream: OutputStream) {
         let messageBytes: [UInt8] = [
             0xc0,                               // FIXED BYTE 1   c = PINGREQ, 0 = DUP QoS RETAIN (not used)

                        }

                        let topicPointer = UnsafeBufferPointer(start: messageBuffer + 2, count: topicLength)
                        guard let topic = String(bytes: topicPointer, encoding: String.Encoding.utf8) else {
                            messageParserState = .decodingHeader
                            break
                        }

                        let pointer = UnsafeBufferPointer(start: messageBuffer + topicLength + 2,
                                                          count: byteCount - topicLength - 2)

                        if let closure = receivingMessage, let message = String(bytes: pointer, encoding: .utf8) {
                            closure(topic, message)
                        }

