[transferring] Change CheckedContinuation.resume and Async{Throwing,}Stream.yield to use transferring parameters.

Importantly, I used silgen_name to preserve the name since I have not yet
removed the mangling for transferring for named entities. This ensures that
this is an ABI neutral change until I make that other change.

rdar://120420024

Author: gottesmm

stdlib/public/Concurrency/AsyncStream.swift

@@ -191,8 +191,9 @@ public struct AsyncStream<Element> {
     ///
     /// This can be called more than once and returns to the caller immediately
     /// without blocking for any awaiting consumption from the iteration.
+    @_silgen_name("$sScS12ContinuationV5yieldyAB11YieldResultOyx__GxnF")
     @discardableResult
-    public func yield(_ value: __owned Element) -> YieldResult {
+    public func yield(_ value: transferring Element) -> YieldResult {
       storage.yield(value)
     }
 
@@ -421,12 +422,15 @@ extension AsyncStream.Continuation {
   /// If you call this method repeatedly, each call returns immediately, without
   /// blocking for any awaiting consumption from the iteration.
   @discardableResult
+  @_silgen_name("$sScS12ContinuationV5yield4withAB11YieldResultOyx__Gs0E0Oyxs5NeverOG_tF")
   public func yield(
-    with result: Result<Element, Never>
+    with result: transferring borrowing Result<Element, Never>
   ) -> YieldResult {
-    switch result {
-      case .success(let val):
-        return storage.yield(val)
+    // TODO: Once borrowing values can have borrowing switches, remove this
+    // copy. For now it is necessary though.
+    switch copy result {
+    case .success(let val):
+      return storage.yield(val)
     }
   }
 
@@ -501,7 +505,8 @@ public struct AsyncStream<Element> {
     @discardableResult
     @available(SwiftStdlib 5.1, *)
     @available(*, unavailable, message: "Unavailable in task-to-thread concurrency model")
-    public func yield(_ value: __owned Element) -> YieldResult {
+    @_silgen_name("$sScS12ContinuationV5yieldyAB11YieldResultOyx__GxnF")
+    public func yield(_ value: transferring Element) -> YieldResult {
       fatalError("Unavailable in task-to-thread concurrency model")
     }
     @available(SwiftStdlib 5.1, *)
@@ -570,8 +575,9 @@ extension AsyncStream.Continuation {
   @discardableResult
   @available(SwiftStdlib 5.1, *)
   @available(*, unavailable, message: "Unavailable in task-to-thread concurrency model")
+  @_silgen_name("$sScS12ContinuationV5yield4withAB11YieldResultOyx__Gs0E0Oyxs5NeverOG_tF")
   public func yield(
-    with result: Result<Element, Never>
+    with result: transferring borrowing Result<Element, Never>
   ) -> YieldResult {
     fatalError("Unavailable in task-to-thread concurrency model")
   }

stdlib/public/Concurrency/AsyncThrowingStream.swift

@@ -214,7 +214,8 @@ public struct AsyncThrowingStream<Element, Failure: Error> {
     /// This can be called more than once and returns to the caller immediately
     /// without blocking for any awaiting consumption from the iteration.
     @discardableResult
-    public func yield(_ value: __owned Element) -> YieldResult {
+    @_silgen_name("$sScs12ContinuationV5yieldyAB11YieldResultOyxq___GxnF")
+    public func yield(_ value: transferring Element) -> YieldResult {
       storage.yield(value)
     }
 
@@ -462,10 +463,13 @@ extension AsyncThrowingStream.Continuation {
   /// If you call this method repeatedly, each call returns immediately, without
   /// blocking for any awaiting consumption from the iteration.
   @discardableResult
+  @_silgen_name("$sScs12ContinuationV5yield4withAB11YieldResultOyxs5Error_p__Gs0E0OyxsAG_pG_tsAG_pRs_rlF")
   public func yield(
-    with result: Result<Element, Failure>
+    with result: transferring borrowing Result<Element, Failure>
   ) -> YieldResult where Failure == Error {
-    switch result {
+    // TODO: Once borrowing values can have borrowing switches, remove this
+    // copy. For now it is necessary though.
+    switch copy result {
     case .success(let val):
       return storage.yield(val)
     case .failure(let err):
@@ -547,7 +551,8 @@ public struct AsyncThrowingStream<Element, Failure: Error> {
     @discardableResult
     @available(SwiftStdlib 5.1, *)
     @available(*, unavailable, message: "Unavailable in task-to-thread concurrency model")
-    public func yield(_ value: __owned Element) -> YieldResult {
+    @_silgen_name("$sScs12ContinuationV5yieldyAB11YieldResultOyxq___GxnF")
+    public func yield(_ value: transferring Element) -> YieldResult {
       fatalError("Unavailable in task-to-thread concurrency model")
     }
     @available(SwiftStdlib 5.1, *)
@@ -609,8 +614,9 @@ extension AsyncThrowingStream.Continuation {
   @discardableResult
   @available(SwiftStdlib 5.1, *)
   @available(*, unavailable, message: "Unavailable in task-to-thread concurrency model")
+  @_silgen_name("$sScs12ContinuationV5yield4withAB11YieldResultOyxs5Error_p__Gs0E0OyxsAG_pG_tsAG_pRs_rlF")
   public func yield(
-    with result: Result<Element, Failure>
+    with result: transferring borrowing Result<Element, Failure>
   ) -> YieldResult where Failure == Error {
     fatalError("Unavailable in task-to-thread concurrency model")
   }

stdlib/public/Concurrency/CheckedContinuation.swift

@@ -159,7 +159,8 @@ public struct CheckedContinuation<T, E: Error>: Sendable {
   /// After `resume` enqueues the task, control immediately returns to
   /// the caller. The task continues executing when its executor is
   /// able to reschedule it.
-  public func resume(returning value: __owned T) {
+  @_silgen_name("$sScC6resume9returningyxn_tF")
+  public func resume(returning value: transferring T) {
     if let c: UnsafeContinuation<T, E> = canary.takeContinuation() {
       c.resume(returning: value)
     } else {
@@ -206,8 +207,10 @@ extension CheckedContinuation {
   /// the caller. The task continues executing when its executor is
   /// able to reschedule it.
   @_alwaysEmitIntoClient
-  public func resume<Er: Error>(with result: Result<T, Er>) where E == Error {
-    switch result {
+  public func resume<Er: Error>(with result: transferring borrowing Result<T, Er>) where E == Error {
+    // TODO: Once borrowing values can have borrowing switches, remove this
+    // copy. For now it is necessary though.
+    switch copy result {
       case .success(let val):
         self.resume(returning: val)
       case .failure(let err):
@@ -230,8 +233,10 @@ extension CheckedContinuation {
   /// the caller. The task continues executing when its executor is
   /// able to reschedule it.
   @_alwaysEmitIntoClient
-  public func resume(with result: Result<T, E>) {
-    switch result {
+  public func resume(with result: transferring borrowing Result<T, E>) {
+    // TODO: Once borrowing values can have borrowing switches, remove this
+    // copy. For now it is necessary though.
+    switch copy result {
       case .success(let val):
         self.resume(returning: val)
       case .failure(let err):

test/api-digester/stability-concurrency-abi.test

@@ -97,6 +97,17 @@ Constructor AsyncStream.init(unfolding:onCancel:) has mangled name changing from
 // SerialExecutor gained `enqueue(_: __owned Job)`, protocol requirements got default implementations
 Func SerialExecutor.enqueue(_:) has been added as a protocol requirement
 
+// .yield and .resume here use silgen_name to preserve mangling after adding transferring.
+//
+// Once transferring's mangling has been relazed a little bit, this will go away.
+Func AsyncStream.Continuation.yield(_:) has mangled name changing from 'Swift.AsyncStream.Continuation.yield(__owned A) -> Swift.AsyncStream<A>.Continuation.YieldResult' to 'Swift.AsyncStream.Continuation.yield(transferring __owned A) -> Swift.AsyncStream<A>.Continuation.YieldResult'
+Func AsyncStream.Continuation.yield(with:) has mangled name changing from 'Swift.AsyncStream.Continuation.yield(with: Swift.Result<A, Swift.Never>) -> Swift.AsyncStream<A>.Continuation.YieldResult' to 'Swift.AsyncStream.Continuation.yield(with: transferring Swift.Result<A, Swift.Never>) -> Swift.AsyncStream<A>.Continuation.YieldResult'
+Func AsyncStream.Continuation.yield(with:) has parameter 0 changing from Default to Shared
+Func AsyncThrowingStream.Continuation.yield(_:) has mangled name changing from 'Swift.AsyncThrowingStream.Continuation.yield(__owned A) -> Swift.AsyncThrowingStream<A, B>.Continuation.YieldResult' to 'Swift.AsyncThrowingStream.Continuation.yield(transferring __owned A) -> Swift.AsyncThrowingStream<A, B>.Continuation.YieldResult'
+Func AsyncThrowingStream.Continuation.yield(with:) has mangled name changing from 'Swift.AsyncThrowingStream.Continuation.yield< where B == Swift.Error>(with: Swift.Result<A, Swift.Error>) -> Swift.AsyncThrowingStream<A, Swift.Error>.Continuation.YieldResult' to 'Swift.AsyncThrowingStream.Continuation.yield< where B == Swift.Error>(with: transferring Swift.Result<A, Swift.Error>) -> Swift.AsyncThrowingStream<A, Swift.Error>.Continuation.YieldResult'
+Func AsyncThrowingStream.Continuation.yield(with:) has parameter 0 changing from Default to Shared
+Func CheckedContinuation.resume(returning:) has mangled name changing from 'Swift.CheckedContinuation.resume(returning: __owned A) -> ()' to 'Swift.CheckedContinuation.resume(returning: transferring __owned A) -> ()'
+
 // We deprecated `enqueue(_: UnownedJob)` and annotate it as such for all platforms,
 // while adding a new overload that accepts `Job` with new availability.
 // The ABI checker seems to be confused by this case.