Method trigger

packages/service-worker/worker/src/idle.ts:37–66

()

  ) {}

  async trigger(): Promise<void> {
    this.lastTrigger = this.adapter.time;
    if (this.queue.length === 0) {
      return;
    }

    if (this.scheduled !== null) {
      this.scheduled.cancel = true;
    }

    const scheduled = {
      cancel: false,
    };
    this.scheduled = scheduled;

    // Ensure that no task remains pending for longer than `this.maxDelay` ms.
    const now = this.adapter.time;
    const maxDelay = Math.max(0, (this.oldestScheduledAt ?? now) + this.maxDelay - now);
    const delay = Math.min(maxDelay, this.delay);

    await this.adapter.timeout(delay);

    if (scheduled.cancel) {
      return;
    }

    this.scheduled = null;

    await this.execute();
  }

  async execute(): Promise<void> {
    this.lastRun = this.adapter.time;