resolve on error

2026-02-21 23:11:44 +00:00 · 2023-02-01 03:07:35 +01:00
parent e4bd87bbfe
commit 0b395d1f59
1 changed files with 1 additions and 0 deletions
--- a/packages/microservices/server/server-kafka.ts
+++ b/packages/microservices/server/server-kafka.ts
@@ -220,6 +220,7 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
            reject(err);
          }
          replayStream$.error(err);
+          resolve();
        },
        complete: () => replayStream$.complete(),
      });