gistfile1.txt

public func connect(url: URL, timeout: Double = 10, certificatePinning: CertificatePinning? = nil) {
    guard let parts = url.getParts() else {
        delegate?.connectionChanged(state: .failed(FoundationTransportError.invalidRequest))
        return
    }
    self.certPinner = certificatePinning
    self.isTLS = parts.isTLS
    var readStream: Unmanaged<CFReadStream>?
    var writeStream: Unmanaged<CFWriteStream>?
    let h = parts.host as NSString
    CFStreamCreatePairWithSocketToHost(nil, h, UInt32(parts.port), &readStream, &writeStream)
    inputStream = readStream!.takeRetainedValue()
    outputStream = writeStream!.takeRetainedValue()
    guard let inStream = inputStream, let outStream = outputStream else {
            return
    }
    inStream.delegate = self
    outStream.delegate = self

    if isTLS {
        let key = CFStreamPropertyKey(rawValue: kCFStreamPropertySocketSecurityLevel)
        CFReadStreamSetProperty(inStream, key, kCFStreamSocketSecurityLevelNegotiatedSSL)
        CFWriteStreamSetProperty(outStream, key, kCFStreamSocketSecurityLevelNegotiatedSSL)
    }
    
    onConnect?(inStream, outStream)
    
    isOpen = false
    CFReadStreamSetDispatchQueue(inStream, workQueue)
    CFWriteStreamSetDispatchQueue(outStream, workQueue)
    inStream.open()
    outStream.open()
    
    
    workQueue.asyncAfter(deadline: .now() + timeout, execute: { [weak self] in
        guard let s = self else { return }
        if !s.isOpen {
            s.delegate?.connectionChanged(state: .failed(FoundationTransportError.timeout))
        }
    })
}