Method connect

packages/@wterm/core/src/transport.ts:36–69

(url?: string)

  }

  connect(url?: string): void {
    if (url) this.url = url;
    if (!this.url) throw new Error("No WebSocket URL provided");

    this._closed = false;
    this._ws = new WebSocket(this.url);
    this._ws.binaryType = "arraybuffer";

    this._ws.onopen = () => {
      this._reconnectDelay = 1000;
      this._flushBuffer();
      if (this.onOpen) this.onOpen();
    };

    this._ws.onmessage = (event: MessageEvent) => {
      if (this.onData) {
        if (event.data instanceof ArrayBuffer) {
          this.onData(new Uint8Array(event.data));
        } else {
          this.onData(event.data as string);
        }
      }
    };

    this._ws.onclose = () => {
      if (this.onClose) this.onClose();
      if (this.reconnect && !this._closed) this._scheduleReconnect();
    };

    this._ws.onerror = (event) => {
      if (this.onError) this.onError(event);
      this._ws?.close();
    };
  }

  send(data: string | Uint8Array): void {
    if (this._ws && this._ws.readyState === WebSocket.OPEN) {