Support streaming streaming responses for callable functions.

common/api-review/functions.api.md

@@ -35,13 +35,16 @@ export type FunctionsErrorCodeCore = 'ok' | 'cancelled' | 'unknown' | 'invalid-a
 export function getFunctions(app?: FirebaseApp, regionOrCustomDomain?: string): Functions;
 
 // @public
-export type HttpsCallable<RequestData = unknown, ResponseData = unknown> = (data?: RequestData | null) => Promise<HttpsCallableResult<ResponseData>>;
+export type HttpsCallable<RequestData = unknown, ResponseData = unknown, StreamData = unknown> = {
+    (data?: RequestData | null): Promise<HttpsCallableResult<ResponseData>>;
+    stream: (data?: RequestData | null, options?: HttpsCallableStreamOptions) => Promise<HttpsCallableStreamResult<ResponseData, StreamData>>;
+};
 
 // @public
-export function httpsCallable<RequestData = unknown, ResponseData = unknown>(functionsInstance: Functions, name: string, options?: HttpsCallableOptions): HttpsCallable<RequestData, ResponseData>;
+export function httpsCallable<RequestData = unknown, ResponseData = unknown, StreamData = unknown>(functionsInstance: Functions, name: string, options?: HttpsCallableOptions): HttpsCallable<RequestData, ResponseData, StreamData>;
 
 // @public
-export function httpsCallableFromURL<RequestData = unknown, ResponseData = unknown>(functionsInstance: Functions, url: string, options?: HttpsCallableOptions): HttpsCallable<RequestData, ResponseData>;
+export function httpsCallableFromURL<RequestData = unknown, ResponseData = unknown, StreamData = unknown>(functionsInstance: Functions, url: string, options?: HttpsCallableOptions): HttpsCallable<RequestData, ResponseData, StreamData>;
 
 // @public
 export interface HttpsCallableOptions {
@@ -54,5 +57,18 @@ export interface HttpsCallableResult<ResponseData = unknown> {
     readonly data: ResponseData;
 }
 
+// @public
+export interface HttpsCallableStreamOptions {
+    signal?: AbortSignal;
+}
+
+// @public
+export interface HttpsCallableStreamResult<ResponseData = unknown, StreamData = unknown> {
+    // (undocumented)
+    readonly data: Promise<ResponseData>;
+    // (undocumented)
+    readonly stream: AsyncIterable<StreamData>;
+}
+
 
 ```

packages/functions-types/index.d.ts

@@ -22,12 +22,21 @@ export interface HttpsCallableResult {
   readonly data: any;
 }
 
+/**
+ * An HttpsCallableStreamResult wraps a single streaming result from a function call.
+ */
+export interface HttpsCallableStreamResult {
+  readonly data: Promise<any>;
+  readonly stream: AsyncIterable<any>;
+}
+
 /**
  * An HttpsCallable is a reference to a "callable" http trigger in
  * Google Cloud Functions.
  */
 export interface HttpsCallable {
   (data?: {} | null): Promise<HttpsCallableResult>;
+  stream(data?: {} | null): Promise<HttpsCallableStreamResult>;
 }
 
 /**

packages/functions/package.json

@@ -37,7 +37,8 @@
     "test:browser": "karma start",
     "test:browser:debug": "karma start --browsers=Chrome --auto-watch",
     "test:node": "TS_NODE_COMPILER_OPTIONS='{\"module\":\"commonjs\"}' nyc --reporter lcovonly -- mocha 'src/{,!(browser)/**/}*.test.ts' --file src/index.ts --config ../../config/mocharc.node.js",
-    "test:emulator": "env FIREBASE_FUNCTIONS_EMULATOR_ORIGIN=http://localhost:5005 run-p --npm-path npm test:node",
+    "test:emulator": "env FIREBASE_FUNCTIONS_EMULATOR_ORIGIN=http://127.0.0.1:5005 run-p test:node",
+    "test:emulator": "env FIREBASE_FUNCTIONS_EMULATOR_ORIGIN=http://127.0.0.1:5005 run-p --npm-path npm test:node",
     "trusted-type-check": "tsec -p tsconfig.json --noEmit",
     "api-report": "api-extractor run --local --verbose",
     "doc": "api-documenter markdown --input temp --output docs",

packages/functions/src/api.ts

@@ -88,12 +88,12 @@ export function connectFunctionsEmulator(
  * @param name - The name of the trigger.
  * @public
  */
-export function httpsCallable<RequestData = unknown, ResponseData = unknown>(
+export function httpsCallable<RequestData = unknown, ResponseData = unknown, StreamData = unknown>(
   functionsInstance: Functions,
   name: string,
   options?: HttpsCallableOptions
-): HttpsCallable<RequestData, ResponseData> {
-  return _httpsCallable<RequestData, ResponseData>(
+): HttpsCallable<RequestData, ResponseData, StreamData> {
+  return _httpsCallable<RequestData, ResponseData, StreamData>(
     getModularInstance<FunctionsService>(functionsInstance as FunctionsService),
     name,
     options
@@ -107,13 +107,14 @@ export function httpsCallable<RequestData = unknown, ResponseData = unknown>(
  */
 export function httpsCallableFromURL<
   RequestData = unknown,
-  ResponseData = unknown
+  ResponseData = unknown,
+  StreamData = unknown,
 >(
   functionsInstance: Functions,
   url: string,
   options?: HttpsCallableOptions
-): HttpsCallable<RequestData, ResponseData> {
-  return _httpsCallableFromURL<RequestData, ResponseData>(
+): HttpsCallable<RequestData, ResponseData, StreamData> {
+  return _httpsCallableFromURL<RequestData, ResponseData, StreamData>(
     getModularInstance<FunctionsService>(functionsInstance as FunctionsService),
     url,
     options