refactor(worker): rename maxConcurrency to maxConcurrent

Update Worker configuration parameter name across multiple files to improve naming consistency.
This includes changes in Worker.ts, index.ts, and README.md to reflect the new parameter name.

Fixes naming inconsistency in worker configuration

pkgs/supaworker/src/Worker.ts

@@ -22,7 +22,7 @@ export interface WorkerConfig {
   maxPollSeconds?: number;
   pollIntervalMs?: number;
   maxPgConnections?: number;
-  maxConcurrency?: number;
+  maxConcurrent?: number;
 }
 
 export class Worker<MessagePayload extends Json> {
@@ -47,7 +47,7 @@ export class Worker<MessagePayload extends Json> {
       maxPollSeconds: config.maxPollSeconds ?? 5,
       pollIntervalMs: config.pollIntervalMs ?? 100,
       maxPgConnections: config.maxPgConnections ?? 4,
-      maxConcurrency: config.maxConcurrency ?? 50,
+      maxConcurrent: config.maxConcurrency ?? 50,
     };
 
     this.sql = postgres(this.config.connectionString, {
@@ -59,7 +59,7 @@ export class Worker<MessagePayload extends Json> {
     this.executionController = new ExecutionController(
       this.queue,
       this.mainController.signal,
-      this.config.maxConcurrency
+      this.config.maxConcurrent
     );
   }
 

pkgs/supaworker/supabase/functions/serial-sleep-worker/index.ts

@@ -3,4 +3,4 @@ import { delay } from 'jsr:@std/async';
 
 const sleep1s = () => delay(1000);
 
-Supaworker.start(sleep1s, { maxConcurrency: 1 });
+Supaworker.start(sleep1s, { maxConcurrent: 1 });

pkgs/supaworker/tests/e2e/README.md

@@ -59,4 +59,4 @@ functions/
 
 ✅ Concurrency
 
-- [ ] Worker respects maxConcurrency (does not read new messages if there are no empty slots, reads max empty-slots-count of messages)
+- [ ] Worker respects maxConcurrent (does not read new messages if there are no empty slots, reads max empty-slots-count of messages)