Streamable functions - Change "stream()" signature.

FirebaseFunctions/Sources/Callable+Codable.swift

@@ -107,7 +107,7 @@ public struct Callable<Request: Encodable, Response: Decodable> {
   /// - Parameter completion: The block to call when the HTTPS request has completed.
   public func call(_ data: Request,
                    completion: @escaping (Result<Response, Error>)
-                     -> Void) {
+                   -> Void) {
     do {
       let encoded = try encoder.encode(data)
 
@@ -154,7 +154,7 @@ public struct Callable<Request: Encodable, Response: Decodable> {
   ///   - completion: The block to call when the HTTPS request has completed.
   public func callAsFunction(_ data: Request,
                              completion: @escaping (Result<Response, Error>)
-                               -> Void) {
+                             -> Void) {
     call(data, completion: completion)
   }
 
@@ -214,7 +214,8 @@ public extension Callable {
   // TODO: Look into handling parameter-less functions.
   // TODO: Ensure decoding failures are passed into reasonable errors.
   @available(macOS 12.0, iOS 15.0, watchOS 8.0, tvOS 15.0, *)
-  func stream(_ data: Request) -> AsyncThrowingStream<Response, Error> {
+  func stream(_ data: Request? = nil) -> AsyncThrowingStream<Response, Error> {
+
     return AsyncThrowingStream { continuation in
       Task {
         do {
@@ -251,14 +252,14 @@ public extension Callable {
               )
               continuation.yield(boxedMessage.message)
             }
+
           }
-        } catch {
-          continuation.finish(throwing: error)
+          continuation.finish()
         }
-        continuation.finish()
       }
     }
   }
+
 }
 
 struct StreamResponseMessage<Message: Decodable>: Decodable {

FirebaseFunctions/Tests/Integration/IntegrationTests.swift

@@ -1121,3 +1121,33 @@ private class AuthTokenProvider: AuthInterop {
 private class MessagingTokenProvider: NSObject, MessagingInterop {
   var fcmToken: String? { return "fakeFCMToken" }
 }
+
+
+extension IntegrationTests {
+  @available(iOS 15.0, *)
+   func testGenStreamContent() async throws {
+       let callable: Callable<String, StreamResponse<String, String>> = functions.httpsCallable("genStream")
+       let stream =  callable.stream("genStream")
+       //TODO fetch actual content.
+       for try await response in stream {
+         switch response {
+           case .message(let message):
+               print("Message: \(message)")
+           case .result(let result):
+               print("Result: \(result)")
+           }
+       }
+   }
+
+   @available(iOS 15.0, *)
+   func testGenStream_NoArgs_ThrowsError() async throws {
+       let callable: Callable<String, StreamResponse<String, String>> = functions.httpsCallable("genStream")
+       let stream =  callable.stream("")
+       //TODO fetch actual content.
+       for try await _ in stream {
+        //TODO add logic to fetch the error after we enable
+         // throw(NSError(domain: "The response cannot be decoded to the given type.", code: 0, userInfo: nil))
+         // back in Callable+Codable func stream(_ data: Request?=nil) -> AsyncThrowingStream<Response, Error>
+       }
+   }
+}