Merge branch 'iOS-Stremable-Functions' of https://github.com/eBlender…

…/firebase-ios-sdk into iOS-Stremable-Functions

FirebaseFunctions/Tests/Unit/FunctionsTests.swift

@@ -405,9 +405,7 @@ class FunctionsTests: XCTestCase {
       XCTExpectFailure("Failed to download stream")
   }
 
-  func testGenerateStreamContentCanceled() async{
-    var response = [String]()
-    let responseQueue = DispatchQueue(label: "responseQueue")
+  func testGenerateStreamContentCanceled() async {
     let options = HTTPSCallableOptions(requireLimitedUseAppCheckTokens: true)
     let input: [String: Any] = ["data": "Why is the sky blue"]
 
@@ -419,28 +417,25 @@ class FunctionsTests: XCTestCase {
         timeout: 4.0
       )
       // First chunk of the stream comes as NSDictionary
-        for try await result in stream {
-          if let dataChunk = result.data as? NSDictionary {
-            for (key, value) in dataChunk {
-              responseQueue.sync {
-                response.append("\(key) \(value)")
-
-            }
-            // Last chunk is the concatenated result so we have to parse it as String else will
-            // fail.
-            if let dataString = result.data as? String {
-              responseQueue.sync {
-                response.append(dataString)
-              }
-            }
+      var response = [String]()
+      for try await result in stream {
+        if let dataChunk = result.data as? NSDictionary {
+          for (key, value) in dataChunk {
+            response.append("\(key) \(value)")
+          }
+        } else {
+          // Last chunk is the concatenated result so we have to parse it as String else will
+          // fail.
+          if let dataString = result.data as? String {
+            response.append(dataString)
           }
         }
-        // Since we cancel the call we are expecting an empty array.
-        XCTAssertEqual(
-          response,
-          []
-        )
       }
+      // Since we cancel the call we are expecting an empty array.
+      XCTAssertEqual(
+        response,
+        []
+      )
     }
     // We cancel the task and we expect a null response even if the stream was initiated.
     task.cancel()