fix: handle stream callback is undefined (#1238)

googleapis · May 3, 2022 · 269f805 · 269f805
1 parent bca9a91
commit 269f805
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/fallbackServiceStub.ts b/src/fallbackServiceStub.ts
@@ -161,7 +161,14 @@ export function generateServiceStub(
               })
               .catch((err: Error) => {
                 if (!cancelRequested || err.name !== 'AbortError') {
-                  callback(err);
+                  if (rpc.responseStream) {
+                    if (callback) {
+                      callback(err);
+                    }
+                    streamArrayParser.emit('error', err);
+                  } else {
+                    callback(err);
+                  }
                 }
               });
           }