2

有没有人成功创建 AsyncStream 并设置它的onTermination处理程序？我做不到。以下内容直接从提案中复制并粘贴（https://github.com/apple/swift-evolution/blob/main/proposals/0314-async-stream.md），除了我通过现代化摆脱了detach警告Task.detached：

    let t = Task.detached {
      func make123Stream() -> AsyncStream<Int> {
        AsyncStream { continuation in
          continuation.onTermination = { termination in
            switch termination {
            case .finished:
                print("Regular finish")
            case .cancelled:
                print("Cancellation")
            }
          }
            Task.detached {
            for n in 1...3 {
              continuation.yield(n)
              sleep(2)
            }
            continuation.finish()
          }
        }
      }

      for await n in make123Stream() {
        print("for-in: \(n)")
      }
      print("After")
    }
    sleep(3)
    t.cancel()

看起来不错，但它不能编译，而且我找不到让它编译的方法。设置器上的错误消息onTermination如下：

 Converting non-concurrent function value to 
 '@Sendable (AsyncStream<Int>.Continuation.Termination) -> Void' 
 may introduce data races

我不知道编译器要我做什么。有没有人解决这个问题，解决方案是什么？

（我已经为此提交了一个错误。）

4

1 回答 1

2

更新：

@Sendable您可以通过添加作为闭包内的第一件事（在捕获列表、参数和in关键字之前）来解决此错误，例如：

continuation.onTermination = { @Sendable termination in
    switch termination {
    case .finished:
        print("Regular finish")
    case .cancelled:
        print("Cancellation")
    @unknown default:
        break
    }
}

原答案：

是的，我猜这是一个错误，因为我可以通过添加以下内容来编译它：

as (@Sendable (AsyncStream<Int>.Continuation.Termination) -> Void)

关闭后，如：

continuation.onTermination = { termination in
    switch termination {
    case .finished:
        print("Regular finish")
    case .cancelled:
        print("Cancellation")
    @unknown default:
        break
    }
} as (@Sendable (AsyncStream<Int>.Continuation.Termination) -> Void)

（我还添加了@unknown default案例以消除出现的新警告。）

于 2021-09-03T16:38:23.073 回答