fix(rx): fix from to forkJoin

sd0xdev · Sep 24, 2023 · 14e70f3 · 14e70f3
1 parent 90fe7dc
commit 14e70f3
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/apps/yggdrasil-discord-client/src/app/discord-bot/discord-bot.service.ts b/apps/yggdrasil-discord-client/src/app/discord-bot/discord-bot.service.ts
@@ -13,6 +13,7 @@ import {
   Subject,
   catchError,
   finalize,
+  forkJoin,
   from,
   lastValueFrom,
   of,
@@ -85,13 +86,11 @@ export class DiscordBotService implements OnApplicationBootstrap {
 
   private messageCreateListenerObservers(message: Message<boolean>) {
     const stopSignal$ = new Subject();
-    return from([
-      this.checkIsBotMessage(message),
-      this.checkShouldReply(message),
-      this.checkIsDisableBotChannel(message),
+    return forkJoin([
+      of(this.checkIsBotMessage(message)),
+      of(this.checkShouldReply(message)),
+      of(this.checkIsDisableBotChannel(message)),
     ]).pipe(
-      take(3),
-      toArray(),
       switchMap((mods) => {
         if (mods.some((mod) => mod === true)) {
           stopSignal$.next('STOP');