Type Alias: QueueProcessor

QueueProcessor = (input, context, signal) => Promise<unknown>

Processes a message: its input, what is known of it, and the signal aborted at its time limit.

Parameters

input

Record<string, any>

context

QueueJobContext

signal

AbortSignal

Returns

Promise<unknown>