Menu
Language
Theme
respond(response: unknown, options: StreamRespondOptions<ConfigurableType>): Promise<void>| Name | Type | Description |
|---|---|---|
response* | unknown | |
options | StreamRespondOptions<ConfigurableType> |
Resume a pending protocol interrupt by sending a response payload back to the interrupted namespace.
When options.interruptId is omitted, walks getThread()?.interrupts
from newest to oldest and resumes the first not yet resolved by a prior
respond() call. That may be a root or subgraph interrupt and is
not necessarily interrupt (interrupts()[0], root-only).
Safe when exactly one interrupt is pending; otherwise pass an explicit
options.interruptId (and options.namespace for subgraph
interrupts).
The server validates namespace against the pending interrupt. Root
interrupts use namespace: [] (default when omitted). For subgraph
interrupts, copy namespace from getThread()?.interrupts.
// Single pending interrupt
await stream.respond({ approved: true });// Multiple root interrupts
for (const intr of stream.interrupts()) {
await stream.respond(decide(intr.value), { interruptId: intr.id! });
}// Subgraph interrupt ā namespace from `getThread()`
const thread = stream.getThread();
for (const entry of thread?.interrupts ?? []) {
await stream.respond(buildResponse(entry.payload), {
interruptId: entry.interruptId,
namespace: entry.namespace,
});
}