Method processQueue

llrt_core/src/modules/js/@llrt/test/SocketClient.ts:50–64

()

  }

  private async processQueue(): Promise<void> {
    if (this.currentlySending || this.queue.length === 0) return;

    const { data, resolve, reject } = this.queue.shift()!;
    this.currentlySending = true;

    try {
      this.currentResolve = resolve;
      await this.sendData(data);
    } catch (err) {
      reject(err);
      this.currentlySending = false;
      this.processQueue();
    }
  }

  private async sendData(data: string): Promise<void> {
    return new Promise((resolve, reject) => {