Add concurrency option

.changeset/cyan-cameras-grin.md

@@ -0,0 +1,15 @@
+---
+"@defer/client": major
+---
+
+Add concurrency limit option.
+
+```js
+import { defer } from "@defer.run/client";
+
+async function oneByOne() {
+  // do something...
+}
+
+export default defer(oneByOne, { concurrency: 1 });
+```

package.json

@@ -1,5 +1,5 @@
 {
-  "name": "@defer.run/client",
+  "name": "@defer/client",
   "version": "0.5.0",
   "description": "Zero infrastructure NodeJS background jobs",
   "main": "dist/cjs/index.js",

src/index.ts

@@ -46,11 +46,64 @@ export type DeferRetFnParameters<
 
 export type RetryNumber = 0 | 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10 | 11 | 12;
 
+export type Concurrency =
+  | 1
+  | 2
+  | 3
+  | 4
+  | 5
+  | 6
+  | 7
+  | 8
+  | 9
+  | 10
+  | 11
+  | 12
+  | 13
+  | 14
+  | 15
+  | 16
+  | 17
+  | 18
+  | 19
+  | 20
+  | 21
+  | 22
+  | 23
+  | 24
+  | 25
+  | 26
+  | 27
+  | 28
+  | 29
+  | 30
+  | 31
+  | 32
+  | 33
+  | 34
+  | 35
+  | 36
+  | 37
+  | 38
+  | 39
+  | 40
+  | 41
+  | 42
+  | 43
+  | 44
+  | 45
+  | 46
+  | 47
+  | 48
+  | 49
+  | 50;
+
 export interface HasDeferMetadata {
   __metadata: {
     version: number;
     cron?: string;
     retry?: RetryNumber;
+    concurrency?: Concurrency;
   };
 }
 
@@ -92,6 +145,7 @@ export const isDeferExecution = (obj: any): obj is DeferExecuteResponse =>
 
 export interface DeferOptions {
   retry?: boolean | RetryNumber;
+  concurrency?: Concurrency;
 }
 
 export const defer: Defer = (fn, options) => {