fix(microservices): fix handling of errors when using observables

nestjs · May 1, 2022 · a09572e · a09572e
1 parent 75eb3f0
commit a09572e
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/packages/microservices/server/server.ts b/packages/microservices/server/server.ts
@@ -5,6 +5,7 @@ import {
   EMPTY,
   from as fromPromise,
   isObservable,
+  lastValueFrom,
   Observable,
   ObservedValueOf,
   of,
@@ -117,11 +118,7 @@ export abstract class Server {
     }
     const resultOrStream = await handler(packet.data, context);
     if (isObservable(resultOrStream)) {
-      const connectableSource = connectable(resultOrStream, {
-        connector: () => new Subject(),
-        resetOnDisconnect: false,
-      });
-      connectableSource.connect();
+      await lastValueFrom(resultOrStream);
     }
   }