         }
 
         DispatchQueue.global(qos: options.readQosClass).async {
-            self.readStream(inputStream: input, outputStream: output)
+            self.readStream(input: input, output: output)
         }
 
         return (input, output)

            messageBuffer.deallocate(capacity: options.bufferSize)
        }

        while inputStream.streamStatus == .open {
            while messageParserState == .decodingHeader && inputStream.streamStatus == .open {
                let count = inputStream.read(messageBuffer, maxLength: 1)
                if count == 0 {
                    break
                } else if count < 0 {

                }
            }

            while messageParserState == .decodingLength && input.streamStatus == .open {
                let count = input.read(messageBuffer, maxLength: 1)
                if count == 0 {
                    break
                } else if count < 0 {
