fix(microservices): multiple scoped event handlers issue #10184

nestjs · Aug 31, 2022 · a5be434 · a5be434
1 parent 697041f
commit a5be434
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/packages/microservices/listeners-controller.ts b/packages/microservices/listeners-controller.ts
@@ -200,7 +200,13 @@ export class ListenersController {
           wrapper.id,
           defaultCallMetadata,
         );
-        requestScopedHandler.next?.(dataOrContextHost, ...args);
+        const returnedValueWrapper = requestScopedHandler.next?.(
+          dataOrContextHost,
+          ...args,
+        );
+        returnedValueWrapper?.then(returnedValue =>
+          this.connectIfStream(returnedValue as Observable<unknown>),
+        );
         return proxy(...args);
       } catch (err) {
         let exceptionFilter = this.exceptionFiltersCache.get(