ExtractionConsumer

@forge/monorepo

---

@forge/monorepo / backend/src / ExtractionConsumer

Interface: ExtractionConsumer

Defined in: backend/src/worker/extraction.ts:22

The consumer side. Mirrors JobConsumer for runs; stop must stop accepting before it waits.

Methods

start()

start(handler): void | Promise<void>

Defined in: backend/src/worker/extraction.ts:23

Parameters

handler

(job) => Promise<void>

Returns

void | Promise<void>

---

stop()

stop(graceMs): Promise<void>

Defined in: backend/src/worker/extraction.ts:24

Parameters

graceMs

number

Returns

Promise<void>