MCPcopy Create free account

hub / github.com/langchain-ai/langgraphjs / functions

Functions4,051 in github.com/langchain-ai/langgraphjs

↓ 3 callersMethodgetTuple
( config: RunnableConfig )
libs/langgraph-core/src/tests/python_port/checkpoint.test.ts:1826
↓ 3 callersMethodgetTuple
(config: RunnableConfig)
libs/checkpoint/src/memory.ts:155
↓ 3 callersFunctionheapDelta
Run fn, return heap delta in bytes.
internal/bench/src/memory.bench.test.ts:53
↓ 3 callersFunctionhighlightCode
( code: string, language: BundledLanguage, // oxlint-disable-next-line eslint-plugin-promise(prefer-awai
examples/ai-elements/src/components/ai-elements/code-block.tsx:175
↓ 3 callersFunctioninv64
(x: bigint)
libs/langgraph-core/src/hash.ts:402
↓ 3 callersFunctionisCheckpointEnvelope
(payload: unknown)
libs/langgraph-core/src/stream/convert.ts:42
↓ 3 callersFunctionisRoot
(namespace: readonly string[])
libs/sdk-vue/src/selectors.ts:93
↓ 3 callersFunctionisSkippedCIEnvironment
()
libs/checkpoint-validation/src/tests/utils.ts:31
↓ 3 callersFunctionisStreamChannel
( value: unknown )
libs/langgraph-core/src/stream/stream-channel.ts:267
↓ 3 callersFunctionisToolNamespaceSegment
(segment: string)
libs/sdk/src/stream/namespace.ts:20
↓ 3 callersMethodisValidSubagent
* Check if a subagent should be exposed through the public API. * * We expose subagents as soon as their parent AI message emits a complete *
libs/sdk/src/ui/subagents.ts:446
↓ 3 callersMethodisWriter
(runnable: RunnableLike)
libs/langgraph-core/src/pregel/write.ts:148
↓ 3 callersFunctionit_skipForSomeModules
( checkpointerName: string, skippedCheckpointers: Record<CheckpointerName, WhySkipped> )
libs/checkpoint-validation/src/test_utils.ts:23
↓ 3 callersFunctionlegacyChatGraph
(saver: PostgresSaver)
libs/langgraph-core/src/tests/delta_channel.postgres.int.test.ts:96
↓ 3 callersMethodlist
( config: RunnableConfig, options?: CheckpointListOptions )
libs/checkpoint-sqlite/src/index.ts:227
↓ 3 callersMethodlist
()
libs/checkpoint/src/tests/checkpoints.test.ts:115
↓ 3 callersFunctionmakeGraph
()
libs/langgraph-core/src/state/values/delta.test.ts:155
↓ 3 callersFunctionmakeNarratorNode
(index: number)
examples/ui-multimodal/src/agent.ts:256
↓ 3 callersFunctionmakeRootBus
(channels: readonly Channel[] = ["lifecycle"])
libs/sdk/src/stream/projections/channel.test.ts:8
↓ 3 callersFunctionmakeTransformer
(id: number)
libs/langgraph-core/src/stream/mux.test.ts:394
↓ 3 callersFunctionmakeVisualizerNode
(index: number)
examples/ui-multimodal/src/agent.ts:230
↓ 3 callersFunctionmapOutputUpdates
( outputChannels: C | Array<C>, tasks: readonly [PregelExecutableTask<N, C>, PendingWrite<C>[]][], cache
libs/langgraph-core/src/pregel/io.ts:202
↓ 3 callersMethodmatchSubgraphToSubagent
* Try to match a subgraph to a pending subagent by description. * Creates a mapping from namespace ID to tool call ID if a match is found. *
libs/sdk/src/ui/subagents.ts:324
↓ 3 callersFunctionmergeHeaders
( ...headerObjects: ( | HeadersInit | Record<string, HeaderValue> | undefined | null )[] )
libs/sdk/src/client/base.ts:56
↓ 3 callersFunctionmixedPositionalState
A pending checkpoint with arbitrary mixed tool_calls and push tasks.
libs/sdk/src/stream/discovery/namespace-from-history.test.ts:80
↓ 3 callersFunctionmountThread
(client: Client)
libs/sdk/src/react/stream.lgp.test.tsx:44
↓ 3 callersFunctionnamespaceKey
(ns: Namespace)
libs/sdk/src/client/stream/index.ts:171
↓ 3 callersFunctionnamespaceKey
(namespace: readonly string[])
libs/sdk-angular/src/selectors.ts:132
↓ 3 callersFunctionnormalizedMessageId
(message: BaseMessage)
libs/sdk/src/stream/message-reconciliation.ts:236
↓ 3 callersMethodobserveIndex
Track a block index for the monotonic-ordering diagnostic.
libs/sdk/src/client/stream/media.ts:297
↓ 3 callersMethodopenEventStream
* Opens an independent filtered SSE event stream. * Each call creates a new server connection with the given filter. * Returns `undefined` when
libs/sdk/src/client/stream/transport.ts:87
↓ 3 callersFunctionparseNodeName
* LangGraph namespaces a node invocation as `<node_name>:<uuid>` * (parallel fan-outs share `<node_name>` as a prefix but each get a * fresh uuid).
libs/sdk/src/stream/discovery/subgraphs.ts:78
↓ 3 callersFunctionparseToolMessageRecord
(message: unknown)
libs/sdk/src/client/stream/handles/tools.ts:219
↓ 3 callersFunctionpause
()
libs/sdk-vue/src/use-video-player.ts:122
↓ 3 callersMethodpause
()
libs/sdk-vue/src/use-audio-player.ts:56
↓ 3 callersMethodprepareFetchOptions
( path: string, options?: RequestInit & { json?: unknown; params?: Record<string, unknown>
libs/sdk/src/client/base.ts:220
↓ 3 callersFunctionpreview
(value: unknown, max = MAX_PREVIEW)
examples/ui-react/src/agents/timeline-transformer.ts:107
↓ 3 callersFunctionprintStatus
()
examples/streaming/src/subagent-status/remote.ts:51
↓ 3 callersFunctionprintStatus
()
examples/streaming/src/subagent-status/in-process.ts:45
↓ 3 callersFunctionprintStepTasks
( step: number, nextTasks: readonly PregelExecutableTask<N, C>[] )
libs/langgraph-core/src/pregel/debug.ts:349
↓ 3 callersMethodpushEvent
(method: "values" | "lifecycle", data: unknown)
libs/sdk-vue/src/tests/stream.custom-adapter.test.tsx:131
↓ 3 callersFunctionput
(id: string, tenant: string, env: string)
libs/checkpoint-sqlite/src/tests/checkpoints.test.ts:228
↓ 3 callersMethodputWrites
* Store intermediate writes linked to a checkpoint. * * This method saves intermediate writes associated with a checkpoint to the Postgres datab
libs/checkpoint-postgres/src/index.ts:631
↓ 3 callersFunctionreadEvents
( url: string, threadId: string, filter: Record<string, unknown>, max: number, options: { silenceMs?
examples/streaming/src/api/reconnect.ts:98
↓ 3 callersFunctionreadNumber
(record: Record<string, unknown>, key: string)
examples/ui-react/src/components/cards/LocationToolResult.tsx:12
↓ 3 callersFunctionrefreshMemories
()
examples/ui-react/src/views/HeadlessToolsView.tsx:51
↓ 3 callersFunctionrejectPending
(err: Error)
libs/sdk-vue/src/use-video-player.ts:86
↓ 3 callersFunctionreplayRootProjection
(events: readonly Event[])
libs/sdk/src/stream/root-message-projection.test.ts:156
↓ 3 callersMethodreplayWrites
(writes: DeltaChannelHistory["writes"])
libs/langgraph-core/src/channels/base.ts:180
↓ 3 callersFunctionresolvePending
()
libs/sdk-vue/src/use-video-player.ts:80
↓ 3 callersFunctionresolveSubagentNamespaceFor
* Lazily resolve a subagent's execution namespace on first scoped use. * Must be called from an injection context (as the selector primitives * are)
libs/sdk-angular/src/selectors.ts:116
↓ 3 callersMethodrespond
* Respond to a single pending protocol interrupt. * * When `options.interruptId` is omitted, resolution walks * {@link ThreadStream.interrupt
libs/sdk/src/stream/controller.ts:1262
↓ 3 callersMethodrespondAll
* Resume several pending interrupts at the same checkpoint in a single * command. * * Required when a run pauses on multiple interrupts simul
libs/sdk/src/stream/controller.ts:1373
↓ 3 callersMethodrespondInput
* Respond to an interrupt without the v1 eager lazy-getter shims. * See {@link submitRun} for why this exists alongside * {@link input.respond}.
libs/sdk/src/client/stream/index.ts:1380
↓ 3 callersMethodreturn
()
libs/sdk/src/utils/stream.ts:377
↓ 3 callersFunctionrunOnce
( url: string, label: string, options: { namespaces?: readonly (readonly string[])[]; depth?: number } )
examples/streaming/src/api/subgraphs.ts:110
↓ 3 callersFunctionrunPregelTests
( createCheckpointer: () => BaseCheckpointSaver | Promise<BaseCheckpointSaver>, teardown?: () => any )
libs/langgraph-core/src/tests/pregel.test.ts:146
↓ 3 callersMethodseedFromHistory
* Seed subgraph hosts from checkpoint history (see * `namespace-from-history.collectSubgraphHostNamespaces`) so subgraph * cards render on threa
libs/sdk/src/stream/discovery/subgraphs.ts:233
↓ 3 callersFunctionsetInitialValuesFixture
(values: InitialValuesState)
libs/sdk-angular/src/tests/components/InitialValuesStream.ts:14
↓ 3 callersMethodsetItem
(key: `lg:stream:${string}`, value: string)
libs/sdk/src/ui/types.ts:1317
↓ 3 callersMethodsimulateMessage
(payload: unknown)
libs/sdk/src/client/stream/transport/websocket.test.ts:76
↓ 3 callersMethodsimulateUnexpectedClose
()
libs/sdk/src/client/stream/transport/websocket.test.ts:72
↓ 3 callersFunctionsleep
(ms: number)
examples/ui-react/src/agents/tool-streaming.ts:7
↓ 3 callersFunctionsource
()
libs/langgraph-core/src/stream/mux.test.ts:627
↓ 3 callersMethodstart
(controller: ReadableStreamDefaultController<T>)
libs/langgraph-core/src/pregel/stream.ts:84
↓ 3 callersMethodstreamWithRetry
(config: { endpoint: string; method?: string; signal?: AbortSignal; headers?: Record<string, s
libs/sdk/src/client/base.ts:398
↓ 3 callersMethodsubgraphsByNode
()
libs/sdk-angular/src/stream-service.ts:128
↓ 3 callersMethodsubmit
* Submit input to the active thread. * * To resume a pending interrupt, use {@link respond} instead. * * @param input - Input payload for
libs/sdk/src/stream/controller.ts:1086
↓ 3 callersMethodsubscribeEvents
* Returns an async iterator that yields only events whose namespace * starts with {@link path}. * * @param path - Namespace prefix to filter
libs/langgraph-core/src/stream/mux.ts:455
↓ 3 callersFunctionsummarizeByNamespace
(events: Event[])
examples/streaming/src/api/subgraphs.ts:135
↓ 3 callersMethodsyncThreadId
* Synchronize the external thread ID with the orchestrator. * If the ID has changed, the current stream is cleared and listeners * are notified.
libs/sdk/src/ui/orchestrator-custom.ts:168
↓ 3 callersFunctiontoClientAssembledToolCall
( handle: MutableToolCallHandle )
libs/sdk/src/client/stream/handles/tools.ts:86
↓ 3 callersFunctiontoolEvent
(data: ToolsEvent["params"]["data"])
libs/sdk/src/stream/discovery/subagents.test.ts:19
↓ 3 callersFunctiontryCoerceMessageLikeToMessage
( message: MessageLike )
libs/sdk/src/stream/message-coercion.ts:36
↓ 3 callersFunctiontryDispose
* Best-effort runtime disposal. * * `dispose()` should never throw, but a misbehaving projection should * not be able to wedge the entire registry.
libs/sdk/src/stream/channel-registry.ts:300
↓ 3 callersFunctionunwrap
(input: ValueOrGetter<T>)
libs/sdk-svelte/src/use-audio-player.svelte.ts:296
↓ 3 callersFunctionuseAudio
( stream: AnyStream, target?: SelectorTarget )
libs/sdk-react/src/selectors.ts:320
↓ 3 callersFunctionuseImages
( stream: AnyStream, target?: SelectorTarget )
libs/sdk-react/src/selectors.ts:340
↓ 3 callersFunctionuseResolveSubagentNamespace
* Lazily resolve a subagent's execution namespace on the first scoped * mount. Deep-agent subagents execute under a `tools:<uuid>` namespace * disti
libs/sdk-react/src/selectors.ts:113
↓ 3 callersFunctionuseResolveSubagentNamespace
* Lazily resolve a subagent's execution namespace on first scoped use. * Re-evaluates when a reactive `target` changes; the controller * de-dupes an
libs/sdk-svelte/src/selectors.svelte.ts:117
↓ 3 callersFunctionuseResolveSubagentNamespace
* Lazily resolve a subagent's execution namespace on first scoped use. * Re-evaluates if `target` changes; the controller de-dupes and skips * alrea
libs/sdk-vue/src/selectors.ts:118
↓ 3 callersFunctionuseStoryApp
()
examples/ui-multimodal/src/lib/useStoryApp.ts:30
↓ 3 callersFunctionuseSubmissionQueue
( stream: AnyStream )
libs/sdk-react/src/selectors.ts:574
↓ 3 callersFunctionuseValues
( stream: AnyStream, target?: SelectorTarget, options?: { messagesKey?: string } )
libs/sdk-vue/src/selectors.ts:221
↓ 3 callersFunctionvaluesEvent
( namespace: readonly string[], data: Record<string, unknown> = {}, seq = 1 )
libs/sdk/src/stream/discovery/subgraphs.test.ts:23
↓ 3 callersFunctionwaitForCheckpointPutToSettle
(logs: string[])
libs/langgraph-core/src/tests/python_port/checkpoint.test.ts:72
↓ 3 callersMethodwithStructuredOutput
(_: unknown)
libs/langgraph-core/src/tests/utils.models.ts:232
↓ 3 callersFunctionwriter
(chunk: T)
libs/langgraph-core/src/writer.ts:4
↓ 3 callersFunctionxorshift64
(b: bigint, shift: bigint)
libs/langgraph-core/src/hash.ts:319
↓ 2 callersMethod#abandonDeferredRootPump
* Abandon a deferred root pump that never started because its * triggering dispatch (`submitRun` / `respondInput`) failed. * * Without this,
libs/sdk/src/stream/controller.ts:1624
↓ 2 callersMethod#applyThreadLevelEffects
(event: Event)
libs/sdk/src/client/stream/index.ts:1590
↓ 2 callersMethod#applyValues
(raw: unknown, checkpoint?: CheckpointEnvelope)
libs/sdk/src/stream/controller.ts:2167
↓ 2 callersMethod#assembleMessage
()
libs/sdk/src/client/stream/messages.ts:414
↓ 2 callersMethod#awaitNextTerminal
* Resolve on the next root-namespace terminal lifecycle event * (`completed` / `failed` / `interrupted`) or on abort. * * Attaches to the con
libs/sdk/src/stream/controller.ts:2310
↓ 2 callersMethod#awaitResumedRunTerminal
* Resolve on the resumed run's root terminal lifecycle. * * Unlike {@link #awaitNextTerminal}, ignores `interrupted` events until a * root `r
libs/sdk/src/stream/controller.ts:2329
↓ 2 callersMethod#awaitRootTerminal
( signal: AbortSignal, options: { skipInterruptedUntilRunning: boolean } )
libs/sdk/src/stream/controller.ts:2338
↓ 2 callersMethod#cancelPendingDispose
* Cancel a deferred dispose scheduled by {@link activate}.
libs/sdk/src/stream/controller.ts:1475
↓ 2 callersMethod#computeUnionFilter
* Progressive-expansion union of every currently-registered * subscription's filter. The server receives the narrowest filter * that still cover
libs/sdk/src/client/stream/index.ts:1832
↓ 2 callersMethod#consumeMediaBlock
({ active, block, blockIndex, dataEvent, namespace, node, terminal, createIfMi
libs/sdk/src/client/stream/media.ts:846
↓ 2 callersMethod#createHydrationPromise
* Create the deferred promise backing the current hydration cycle.
libs/sdk/src/stream/controller.ts:450
← previousnext →901–1,000 of 4,051, ranked by callers