fix(grpc): schedule messages forwarding after the current event loop

nestjs · Nov 27, 2024 · 96e3e79 · 96e3e79
1 parent e411d80
commit 96e3e79
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/packages/microservices/decorators/message-pattern.decorator.ts b/packages/microservices/decorators/message-pattern.decorator.ts
@@ -159,9 +159,7 @@ export function GrpcStreamMethod(
 
       // Drain buffer if "drainBuffer" method is available
       if (observable && observable.drainBuffer) {
-        process.nextTick(() => {
-          observable.drainBuffer();
-        });
+        observable.drainBuffer();
       }
       return result;
     };

diff --git a/packages/microservices/server/server-grpc.ts b/packages/microservices/server/server-grpc.ts
@@ -639,8 +639,10 @@ export class ServerGrpc extends Server implements CustomTransportStrategy {
       hasDrained = true;
 
       // Replay buffered values to the new subscriber
-      replayBuffer.subscribe(subject);
-      replayBuffer.complete();
+      setImmediate(() => {
+        replayBuffer.subscribe(subject);
+        replayBuffer.complete();
+      });
     }
 
     return {