Skip to main content

createMemoryJobDispatcher

@forge/monorepo


@forge/monorepo / backend/src / createMemoryJobDispatcher

Function: createMemoryJobDispatcher()

createMemoryJobDispatcher(process): JobDispatcher & object

Defined in: backend/src/adapters/memory/runtime.ts:249

Synchronous in-memory job dispatcher. Enqueue records the job; drain runs each pending job through the provided processor. Mirrors Twenty's SyncDriver — inline execution for tests.

Parameters

process

(job) => Promise<unknown>

Returns

JobDispatcher & object