Two lines 🤯

rx.js

@@ -4,6 +4,7 @@ import { interval, merge, Observable, of, Subject, timer } from "rxjs";
 import {
   bufferTime,
   catchError,
+  delayWhen,
   filter,
   map,
   mergeAll,
@@ -346,6 +347,9 @@ export class EventManager {
       this.stateMgr.getExtProps(),
       this.authMgr.authToken()
     );
+
+    const isConnected$ = wspub.getStatus().pipe(filter((connected) => connected));
+
     this._publishers.set("ws", wspub);
     merge(
       windowEvent$,
@@ -358,6 +362,7 @@ export class EventManager {
       session$
     )
       .pipe(
+        delayWhen((msg: any) => isConnected$),
         catchError((e) => {
           console.log(e);
           this.channel.appendLine(e);