Interface IPaginationStrategy<TItem, TResult>

paginate

• paginate(
      items: readonly TItem[],
      processor: (item: TItem) => Promise<Procedure<TResult>>,
      ctx: IPipelineContext,
  ): Promise<Procedure<readonly TResult[]>>

  Processes items one at a time, collecting results.

  Parameters

  • items: readonly TItem[]

    Readonly array of items to process.

  • processor: (item: TItem) => Promise<Procedure<TResult>>

    Async function to process each item.

  • ctx: IPipelineContext

    Pipeline context for shutdown checks and logging.

  Returns Promise<Procedure<readonly TResult[]>>

  Procedure with collected results or failure.