diff --git a/src/utils.ts b/src/utils.ts index 595c902..3a199b4 100644 --- a/src/utils.ts +++ b/src/utils.ts @@ -47,8 +47,18 @@ export const withHealthCheckHandling = }; export type ProcessWithOrderingParams = { + /** + * The list of items to process. + */ items: T[]; + /** + * A function for determining the "order" of an item. Should return a + * string that will be used to order items lexicographically. + */ orderBy: (msg: T) => string; + /** + * The limit on the number of items to process concurrently at any time. + */ concurrency: number; };