      * |--------------------------------------
      */
 
-    private func mqttConnect(keepalive: UInt16) {
+    private func mqttConnect(output: OutputStream, keepalive: UInt16) {
         /**
          * |----------------------------------------------------------------------------------
          * |     7    |    6     |      5     |  4   3  |     2    |       1      |     0    |

        let headerBytes: [UInt8] = [
            0x10] +                             // FIXED BYTE 1   1 = CONNECT, 0 = DUP QoS RETAIN, not used in CONNECT
            remainingLengthBytes +              // FIXED BYTE 2+  remaining length
            [0x00,                              // VARIA BYTE 1   length MSB
            0x04,                               // VARIA BYTE 2   length LSB is 4
            0x4d,                               // VARIA BYTE 3   M
            0x51,                               // VARIA BYTE 4   Q

                                break
                            }
                        }

                        messageParserState = .decodingHeader
                        break
                    }
