Class SignalClient

Index

Constructors

Methods

queueMessage sendMessage sendNotificationSignal sendSignal sendStateSignal

Constructors

constructor

new SignalClient(options?: SignalClientOptions): SignalClient
Parameters
- options: SignalClientOptions = {}
Returns SignalClient
- Defined in packages/flowsafe/src/signals/client.ts:105

Methods

queueMessage

queueMessage(threadId: string, body: SendMessageBody): Promise<unknown>
A message delivered on the NEXT turn (never wakes an idle thread).
Parameters
- threadId: string
- body: SendMessageBody
Returns Promise<unknown>
- Defined in packages/flowsafe/src/signals/client.ts:125

sendMessage

sendMessage(threadId: string, body: SendMessageBody): Promise<unknown>
An immediate user message — joins the active loop, or (idle) wakes/persists.
Parameters
- threadId: string
- body: SendMessageBody
Returns Promise<unknown>
- Defined in packages/flowsafe/src/signals/client.ts:120

sendNotificationSignal

sendNotificationSignal(
threadId: string,
body: SendNotificationBody,
): Promise<unknown>
A durable AGENT inbox notification (surfaces on the next turn).
Parameters
- threadId: string
- body: SendNotificationBody
Returns Promise<unknown>
- Defined in packages/flowsafe/src/signals/client.ts:146

sendSignal

sendSignal(threadId: string, body: SendSignalBody): Promise<unknown>
A system signal (ifActive/ifIdle deliver/persist/discard/wake).
Parameters
- threadId: string
- body: SendSignalBody
Returns Promise<unknown>
- Defined in packages/flowsafe/src/signals/client.ts:133

sendStateSignal

sendStateSignal(threadId: string, body: SendStateBody): Promise<unknown>
A durable thread-state lane (snapshot/delta, cacheKey dedupe).
Parameters
- threadId: string
- body: SendStateBody
Returns Promise<unknown>
- Defined in packages/flowsafe/src/signals/client.ts:138