@nestjs/microservices
Advanced tools
Comparing version 10.3.5 to 10.3.6
{ | ||
"name": "@nestjs/microservices", | ||
"version": "10.3.5", | ||
"version": "10.3.6", | ||
"description": "Nest - modern, fast, powerful node.js web framework (@microservices)", | ||
@@ -25,4 +25,4 @@ "author": "Kamil Mysliwiec", | ||
"devDependencies": { | ||
"@nestjs/common": "10.3.5", | ||
"@nestjs/core": "10.3.5" | ||
"@nestjs/common": "10.3.6", | ||
"@nestjs/core": "10.3.6" | ||
}, | ||
@@ -29,0 +29,0 @@ "peerDependencies": { |
@@ -159,3 +159,9 @@ "use strict"; | ||
const result$ = this.transformToObservable(await handler); | ||
await this.writeObservableToGrpc(result$, call); | ||
try { | ||
await this.writeObservableToGrpc(result$, call); | ||
} | ||
catch (err) { | ||
call.emit('error', err); | ||
return; | ||
} | ||
}; | ||
@@ -281,3 +287,9 @@ } | ||
if (isResponseStream) { | ||
await this.writeObservableToGrpc(res, call); | ||
try { | ||
await this.writeObservableToGrpc(res, call); | ||
} | ||
catch (err) { | ||
call.emit('error', err); | ||
return; | ||
} | ||
} | ||
@@ -284,0 +296,0 @@ else { |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
390997
9452