From f416f5af790e03199707af650e6f5ab335bcf42f Mon Sep 17 00:00:00 2001 From: Kamil Mysliwiec Date: Wed, 27 Mar 2024 08:34:38 +0100 Subject: [PATCH] Revert "fix(microservices): fix redundant code to emit error" --- packages/microservices/server/server-grpc.ts | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/packages/microservices/server/server-grpc.ts b/packages/microservices/server/server-grpc.ts index 815d9b437a1..84b3c552bd1 100644 --- a/packages/microservices/server/server-grpc.ts +++ b/packages/microservices/server/server-grpc.ts @@ -242,7 +242,12 @@ export class ServerGrpc extends Server implements CustomTransportStrategy { const handler = methodHandler(call.request, call.metadata, call); const result$ = this.transformToObservable(await handler); - await this.writeObservableToGrpc(result$, call); + try { + await this.writeObservableToGrpc(result$, call); + } catch (err) { + call.emit('error', err); + return; + } }; } @@ -381,7 +386,12 @@ 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(