Method paginate

integrations/replicate/src/index.ts:114–136

Paginate through a list of results.

(
    task: (key: string) => Promise<Page<T>>,
    key: IntegrationTaskKey,
    counter: number = 0
  )

  /** Paginate through a list of results. */
  async *paginate<T>(
    task: (key: string) => Promise<Page<T>>,
    key: IntegrationTaskKey,
    counter: number = 0
  ): AsyncGenerator<T[]> {
    const boundTask = task.bind(this as any);

    const page = await boundTask(`${key}-${counter}`);
    yield page.results;

    if (page.next) {
      const nextStep = counter++;

      const nextPage = () => {
        return this.request<Page<T>>(`${key}-${nextStep}`, {
          route: page.next!,
          options: { method: "GET" },
        });
      };

      yield* this.paginate(nextPage, key, nextStep);
    }
  }

  /** Auto-paginate and return all results. */
  async getAll<T>(