 
     // MARK: - Socket connection
 
-    private func openStreams() -> (inputStream: InputStream, outputStream: OutputStream)? {
+    private func openStreams() -> (input: InputStream, output: OutputStream)? {
         var inputStream: InputStream?
         var outputStream: OutputStream?
 
-        Stream.getStreamsToHost(withName: host, port: options.concretePort, inputStream: &inputStream, outputStream: &outputStream)
+        Stream.getStreamsToHost(withName: host,
+                                port: options.concretePort,
+                                inputStream: &inputStream,
+                                outputStream: &outputStream)
 
         guard let input = inputStream, let output = outputStream else {
             return nil

                    }

                    let bytesToRead = min(options.bufferSize - byteCount, messageLength - byteCount)
                    let count = inputStream.read(messageBuffer.advanced(by: byteCount), maxLength: bytesToRead)
                    if count == 0 {
                        break
                    } else if count < 0 {

                }
            }

            while messageParserState == .decodingData && input.streamStatus == .open {
                switch messageType {
                case .publish:
                    guard messageLength > 0 else {
