Merge pull request #12673 from Hellomik2002/catch-stream-error-grpc

FIX catch stream errors in grpc
nestjs · Nov 17, 2023 · a3f3b97 · a3f3b97
2 parents e00fb64 + 8dfba64
commit a3f3b97
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/packages/microservices/server/server-grpc.ts b/packages/microservices/server/server-grpc.ts
@@ -381,7 +381,13 @@ export class ServerGrpc extends Server implements CustomTransportStrategy {
       const handler = methodHandler(req.asObservable(), call.metadata, call);
       const res = this.transformToObservable(await handler);
       if (isResponseStream) {
-        await this.writeObservableToGrpc(res, call);
+        try {
+          await this.writeObservableToGrpc(res, call);
+        }
+        catch (err) {
+          call.emit('error', err);
+          return;
+        }
       } else {
         const response = await lastValueFrom(
           res.pipe(