injectStream

injectStream is the root hook of @langchain/angular. Mount it once per thread. It owns the thread lifecycle, the transport, and a handful of always-on projections (values, messages, toolCalls, interrupts, error, isLoading, discovery maps).

Learn more: New to the SDK? Start with Getting started. For UI patterns, see the LangChain frontend documentation.

Runnable example: The ui-angular app in the streaming cookbook is a complete injectStream chat with reconnect and replay.

Options

The option bag is a discriminated union on transport:

• Agent Server (default) — omit transport, or pass "sse" / "websocket". Requires assistantId + apiUrl (or a pre-built client).
• Custom adapter — pass an AgentServerAdapter instance. The hook delegates every command and subscription to the adapter. See Transports.

Common options

Option	Type	Description
assistantId	string	Assistant/graph ID. Required on the Agent Server branch; optional (defaults to "_") on the custom-adapter branch.
threadId	string \| null	Bind to an existing thread. Pass null to start a new thread on next submit; changing the value hydrates and resubscribes.
initialValues	StateType	Initial state values used until the first values event lands.
messagesKey	string	State key holding the message array. Defaults to "messages".
onThreadId	(id: string) => void	Fires when the server mints a new thread id.
onCreated	(info: { runId: string }) => void	Fired when this hook's run is accepted by the server.
onCompleted	(info: { runId?: string; reason: "success" \| "error" \| "interrupt" \| "stopped" }) => void	Fired when a run's active streaming phase ends. runId may be omitted for re-attached in-flight runs.
tools	HeadlessToolImplementation[]	Headless tools. Matching interrupts are auto-resolved with the handler's return value. See Interrupts.
onTool	OnToolCallback	Observe headless-tool lifecycle events (start / success / error).

Agent Server branch (AgentServerOptions)

Option	Type	Description
apiUrl	string	Base URL of the LangGraph-compatible agent server.
client	Client	Pre-built SDK client (alternative to apiUrl).
apiKey	string	API key forwarded to the built-in client.
callerOptions, defaultHeaders	ClientConfig[...]	Forwarded to the built-in client.
transport	"sse" \| "websocket"	Built-in wire transport. Defaults to "sse".
fetch	typeof fetch	Optional fetch override for the SSE transport.
webSocketFactory	(url: string) => WebSocket	Optional WebSocket factory for the WS transport.

Custom-adapter branch (CustomAdapterOptions)

Option	Type	Description
transport	AgentServerAdapter	Adapter instance. Replaces the built-in transport stack entirely.

Passing apiUrl / apiKey / fetch / webSocketFactory on the custom-adapter branch is a compile-time error.

Return values

Property	Type	Description
values	StateType	Latest root values-channel snapshot (falls back to initialValues ?? {}).
messages	BaseMessage[]	Root message projection; merges messages-channel deltas and values.messages snapshots.
toolCalls	AssembledToolCall[]	Tool calls assembled from the root run; each carries status, args, result, aiMessageId.
interrupt / interrupts	Interrupt \| Interrupt[]	Most-recent root interrupt and the full interrupt list.
isLoading	boolean	True while a run is in flight or initial hydration hasn't completed.
isThreadLoading	boolean	True during the initial thread-hydration lifecycle.
hydrationPromise	Promise<void>	Settles when the active thread's initial hydrate resolves. Used by injectStream.
error	unknown	Latest transport or hydrate error.
threadId	string \| null	Currently bound thread id.
subagents	ReadonlyMap<string, SubagentDiscoverySnapshot>	Discovery snapshots for subagents on the thread (identity only — no messages / tool calls).
subgraphs	ReadonlyMap<string, SubgraphDiscoverySnapshot>	Subgraphs discovered on the run.
subgraphsByNode	ReadonlyMap<string, readonly SubgraphDiscoverySnapshot[]>	Same snapshots keyed by the graph node that produced them.
submit(input, options?)	function	Dispatch a new run on the bound thread.
stop(options?)	(options?: { cancel?: boolean }) => Promise<void>	Cancel the active run (default) and disconnect. Pass { cancel: false } to disconnect only.
disconnect()	() => Promise<void>	Disconnect the client without cancelling the run (stop({ cancel: false })).
respond(response, options?)	function	Resume a single interrupt with a response payload (target via options.interruptId / namespace).
respondAll(responsesById, options?)	function	Resume several interrupts pending at the same checkpoint in one command (interruptId → response map).
getThread()	() => ThreadStream \| undefined	Returns the bound ThreadStream for low-level protocol access; undefined until a thread is bound.
client	Client	The bound client (HttpAgentServerAdapter's client on the custom branch).
assistantId	string	Resolved assistant id (including the "_" fallback on custom adapters).

submit() options

submit() accepts Partial<StateType> as input (messages is widened to also accept BaseMessage class instances, or a single message). To resume a pending interrupt, use stream.respond() instead.

Option	Type	Description
config	{ configurable?, tags?, recursion_limit?, ... }	Run config forwarded to the server.
metadata	Record<string, unknown>	Run metadata.
multitaskStrategy	"rollback" \| "interrupt" \| "reject" \| "enqueue"	How to handle a submit while a run is active. See Submission queue.
forkFrom	string	Fork the new run from a specific checkpoint id (edit / retry flows). See Fork & edit from a checkpoint.
interruptBefore, interruptAfter	string[]	Breakpoint debugging.
runId	string	Pre-generate a run id (for optimistic UI / telemetry).
durability	"async" \| "sync" \| "exit"	Checkpoint policy.
context	unknown	Runtime context (distinct from config.configurable).
feedbackKeys	string[]	LangSmith integration.
threadId	string	Per-submit thread override — rebinds the hook to threadId before dispatching.
onError	(error: unknown) => void	Per-submit error callback. The transport-level stream.error store update still happens.

Stopping a run and responding to interrupts

stop()

stream.stop() cancels the active run by default: it disconnects the client transport, calls client.runs.cancel on the server, and sets isLoading to false. Messages and values received so far are preserved. Safe to call unconditionally — when no run is active it is a no-op.

<button onClick={() => void stream.stop()} disabled={!stream.isLoading}>
  Stop
</button>

Pass { cancel: false } to disconnect without cancelling server-side execution, or use stream.disconnect().

disconnect()

stream.disconnect() is an alias for stop({ cancel: false }). Use it in join/rejoin UIs where the agent should keep running after the client leaves the stream.

respond(response, options?)

Resume a single pending interrupt. When options.interruptId is omitted, respond() walks stream.getThread()?.interrupts from newest to oldest and resumes the first entry not yet resolved by a prior respond() call. Safe when exactly one interrupt is pending; otherwise pass options.interruptId (and options.namespace for subgraph interrupts). See Interrupts.

// Single pending interrupt — omit target:
await stream.respond({ approved: true });

// Multiple root interrupts — target by id:
await stream.respond({ approved: true }, { interruptId: myInterrupt.id! });

// Carry run config + metadata onto the resume:
await stream.respond(
  { approved: true },
  { config: { configurable: { model: "gpt-4o" } }, metadata: { source: "ui" } },
);

respondAll(responsesById, options?)

Resume several interrupts pending at the same checkpoint (e.g. parallel tool-authorization prompts) in a single command. responsesById maps each pending interruptId to its response; namespaces are resolved internally from getThread()?.interrupts.

await stream.respondAll({
  [interruptA.id]: { approved: true },
  [interruptB.id]: { approved: false },
});

hydrationPromise

stream.hydrationPromise settles when the thread's initial hydration resolves (or rejects). A fresh promise is installed every time the hook binds to a new threadId. injectStream leans on this directly; in plain injectStream apps you rarely need it.

API reference