Method connect

apps/client/src/code/realtime/client.ts:54–84

()

      }

      connect() {
        super.connect();

        this.socket?.addEventListener('open', () => {
          if (this._isFirstConnection) {
            this._logger.info('First connection');
            this._isFirstConnection = false;
            return;
          }

          this._logger.info('Reconnecting');

          for (const fullKey of Object.keys(this.subscriptions)) {
            const [key, field] = splitStr(fullKey, '>', 2);
            const [prefix, suffix] = splitStr(key, ':', 2);

            this.commandBuffer.push({
              type: RealtimeCommandType.SUBSCRIBE,
              args: [prefix, suffix, field],
            });
          }

          if (this.commandBuffer.length > 0) {
            setTimeout(this.flushCommandBuffer);
          }
        });

        this.socket?.addEventListener('message', (event) => {
          this._handleMessage(new Uint8Array(event.data));
        });
      }

      // Get commands