Skip to content

Function: executeWrite()

executeWrite<T>(operation, settings, fn, signal?): Promise<T>

Run one non-idempotent write through the shared executor and unwrap it.

execute() never throws, so a failed send arrives as { ok: false } with a status the interceptors already sanitized; it is logged here and re-raised as a stable ExecutionError so an upstream message never becomes the caller’s error text. signal is the caller’s own cancellation (an agent run, a request teardown); it is merged with the signal the timeout interceptor supplies so either one unwinds the I/O.

T

string

EmailExecutionSettings

(signal?) => Promise<T>

AbortSignal

Promise<T>