如何实现CocoaAsyncSocket对async/await的适配

目前CocoaAsyncSocket官方主分支并没有提供原生的async/await接口支持，但已经有非常成熟的落地方式，可以完全替换掉原有的delegate写法，简化代码结构。

现有可行路径 #

• 社区已有开发者完成了全量接口的Concurrency封装，覆盖TCP（GCDAsyncSocket）、UDP（GCDAsyncUdpSocket）两类核心对象的所有常用能力：包括连接建立、超时控制、数据收发、状态监听、错误抛出全链路，不需要自己手动处理delegate的生命周期和状态流转。
• 自行封装的成本极低，核心是基于Swift Concurrency提供的续体、异步流API桥接原有delegate回调即可，不需要修改库的源码。
  举个基础的连接方法桥接示例：

  // 临时桥接代理，用来接收delegate回调
  private class AsyncSocketConnectionDelegate: NSObject, GCDAsyncSocketDelegate {
      let continuation: CheckedContinuation<Void, Error>
      init(continuation: CheckedContinuation<Void, Error>) {
          self.continuation = continuation
      }
  
      func socket(_ sock: GCDAsyncSocket, didConnectToHost host: String, port: UInt16) {
          continuation.resume()
      }
  
      func socketDidDisconnect(_ sock: GCDAsyncSocket, withError err: Error?) {
          if let err = err {
              continuation.resume(throwing: err)
          }
      }
  }
  
  private var AsyncSocketDelegateKey: UInt8 = 0
  extension GCDAsyncSocket {
      func connect(host: String, port: UInt16, timeout: TimeInterval = 30) async throws {
          try await withCheckedThrowingContinuation { continuation in
              let bridgeDelegate = AsyncSocketConnectionDelegate(continuation: continuation)
              // 用关联对象持有桥接代理，避免提前释放
              objc_setAssociatedObject(self, &AsyncSocketDelegateKey, bridgeDelegate, .OBJC_ASSOCIATION_RETAIN_NONATOMIC)
              delegate = bridgeDelegate
              delegateQueue = .global()
              connect(toHost: host, onPort: port, withTimeout: timeout)
          }
      }
  }
  

• 对于持续接收数据、监听连接状态这类多回调场景，直接用AsyncStream做桥接即可，把每次delegate回传的数据、状态变更推到流中，调用侧可以直接用for await语法顺序处理，完全不需要拆分delegate方法写零散逻辑。

迁移注意事项 #

• 桥接时必须保证所有逻辑分支下continuation只会被resume一次，重复resume会直接触发Swift运行时崩溃，尤其要覆盖超时、异常断开、主动取消这些边缘场景。
• 迁移不需要全量替换，可以先封装新业务需要用到的接口，老代码保留原有delegate写法逐步迭代，两种调用方式不会产生冲突。
• 注意处理桥接代理的生命周期，在连接断开、任务取消时及时清理关联的临时对象，避免出现循环引用和内存泄漏。

内容的提问来源于stack exchange，提问作者DougPA