MCPcopy Create free account

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

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

↓ 5 callersFunctionmakeProtocolEvent
( method: string, options: MakeProtocolEventOptions = {} )
libs/langgraph-core/src/stream/test-utils.ts:10
↓ 5 callersFunctionmakePushableSubscription
()
libs/sdk/src/stream/controller.test.ts:37
↓ 5 callersFunctionmapper
(value: string)
libs/langgraph-core/src/pregel/read.test.ts:84
↓ 5 callersMethodmarkInterrupted
* Records that the run was interrupted, appending the supplied payloads * for later retrieval. * * @param interrupts - The interrupt payloads
libs/langgraph-core/src/stream/mux.ts:424
↓ 5 callersMethodmarkRunning
* Mark a subagent as running and update its namespace. * * Called when update events are received with a namespace indicating * which subagen
libs/sdk/src/ui/subagents.ts:701
↓ 5 callersFunctionmessagesProjection
( namespace: readonly string[] )
libs/sdk/src/stream/projections/messages.ts:36
↓ 5 callersFunctionnamespaceKey
(namespace: readonly string[])
libs/sdk-svelte/src/selectors.svelte.ts:88
↓ 5 callersFunctionnode
( name: T )
libs/langgraph-core/src/tests/pregel.test.ts:11916
↓ 5 callersFunctionparseToolPayload
(value: unknown)
examples/ui-react/src/components/cards/toolCardUtils.ts:25
↓ 5 callersFunctionreadNumber
(testId: string)
libs/sdk-angular/src/tests/stream.fanout-reconnect.test.ts:18
↓ 5 callersFunctionreadNumber
(testId: string)
libs/sdk-svelte/src/tests/stream.fanout-reconnect.test.ts:16
↓ 5 callersFunctionreadNumber
(testId: string)
libs/sdk-vue/src/tests/stream.fanout-reconnect.test.tsx:18
↓ 5 callersFunctionreadVersion
()
libs/sdk-svelte/src/subagents.ts:26
↓ 5 callersMethodrefreshItemTTL
(docId: string)
libs/checkpoint-redis/src/store.ts:1033
↓ 5 callersMethodrender
()
libs/sdk-react/src/tests/stream.suspense.test.tsx:73
↓ 5 callersMethodresolveReady
* Resolve the `ready` promise of the stream at `index`. Only useful when * constructed with `{ manualReady: true }`.
libs/sdk/src/client/stream/test/utils.ts:170
↓ 5 callersFunctionresolveSubagentNamespaces
( client: Client<TStateType>, threadId: string, toolCallIds: string[], opts?: { limit?: number; messag
libs/sdk/src/stream/discovery/namespace-from-history.ts:211
↓ 5 callersFunctionrunGraphStream
( // eslint-disable-next-line @typescript-eslint/no-explicit-any graph: any, input: Record<string, unkno
internal/bench/src/memory.bench.test.ts:38
↓ 5 callersFunctionscheduleCoalescedHeadlessToolFlush
( handledIds: Set<string>, run: () => void )
libs/sdk/src/headless-tools.ts:447
↓ 5 callersMethodseedFromCheckpointMessages
* Seed discovery from a checkpoint's root `messages` array (as * returned by `client.threads.getState().values.messages`) so deep * agent cards
libs/sdk/src/stream/discovery/subagents.ts:89
↓ 5 callersFunctionsleep
(ms: number)
examples/ui-react/src/agents/shared.ts:5
↓ 5 callersFunctionstr
(value: unknown)
libs/sdk-angular/src/tests/components/OptimisticStream.ts:61
↓ 5 callersMethodsubmitEnqueue
(content: string)
libs/sdk-angular/src/tests/components/QueueStream.ts:84
↓ 5 callersFunctiontoJsonSchema
(schema: InteropZodObject)
libs/langgraph-core/src/graph/zod/schema.ts:70
↓ 5 callersFunctiontoggle
(key: keyof typeof mounts)
libs/sdk-react/src/tests/components/DeepAgentSubscriptionStream.tsx:82
↓ 5 callersFunctiontoggle
(key: keyof InitialMounts)
libs/sdk-vue/src/tests/components/DeepAgentSubscriptionStream.tsx:46
↓ 5 callersFunctionunwrap
(input: ValueOrGetter<T>)
libs/sdk-svelte/src/use-video-player.svelte.ts:6
↓ 5 callersFunctionupsertToolCall
( current: readonly AssembledToolCall[], next: AssembledToolCall )
libs/sdk/src/stream/tool-calls.ts:14
↓ 5 callersFunctionuseExtension
( stream: AnyStream, name: string, target?: SelectorTarget )
libs/sdk-react/src/selectors.ts:293
↓ 5 callersFunctionuseMediaURL
(media: MediaBase | undefined)
libs/sdk-react/src/use-media-url.ts:29
↓ 5 callersFunctionuseMessageBranch
()
examples/ai-elements/src/components/ai-elements/message.tsx:127
↓ 5 callersFunctionuseMessageMetadata
( stream: AnyStream, messageId: ValueOrGetter<string | undefined> )
libs/sdk-svelte/src/selectors.svelte.ts:555
↓ 5 callersFunctionuseMessageMetadata
( stream: AnyStream, messageId: MaybeRefOrGetter<string | undefined> )
libs/sdk-vue/src/selectors.ts:482
↓ 5 callersFunctionuseMessages
( stream: AnyStream, target?: ValueOrGetter<SelectorTarget> )
libs/sdk-svelte/src/selectors.svelte.ts:199
↓ 5 callersFunctionuseProjection
( registry: ValueOrGetter<ChannelRegistry | null | undefined>, specFactory: () => ProjectionSpec<T>, key
libs/sdk-svelte/src/use-projection.svelte.ts:71
↓ 5 callersFunctionuseToolCalls
( stream: AnyStream, target?: ValueOrGetter<SelectorTarget> )
libs/sdk-svelte/src/selectors.svelte.ts:236
↓ 5 callersFunctionuseValues
( stream: AnyStream, target?: ValueOrGetter<SelectorTarget>, options?: { messagesKey?: string } )
libs/sdk-svelte/src/selectors.svelte.ts:285
↓ 5 callersMethodvalidateInput
* Validate input data against the schema. * This validates each field using its corresponding schema. * * @param data - The input data to val
libs/langgraph-core/src/state/schema.ts:390
↓ 5 callersMethodvalues
()
libs/sdk/src/client/stream/handles/subgraphs.ts:143
↓ 5 callersFunctionwithAgentName
( model: LanguageModelLike, agentNameMode: AgentNameMode )
libs/langgraph-core/src/prebuilt/agentName.ts:204
↓ 4 callersMethod#beginOptimistic
* Apply a submit input optimistically to the root projection before * the server responds. Mints stable ids for id-less messages (so the * serve
libs/sdk/src/stream/controller.ts:2065
↓ 4 callersMethod#ensureMediaDispatcher
* Open the single shared `messages`-channel subscription that backs * every media iterable (audio/images/video/files). Idempotent. * * The {@
libs/sdk/src/client/stream/index.ts:1169
↓ 4 callersMethod#ensureMediaDispatcher
()
libs/sdk/src/client/stream/handles/subgraphs.ts:264
↓ 4 callersMethod#ensureMediaDispatcher
()
libs/sdk/src/client/stream/handles/subagents.ts:139
↓ 4 callersMethod#notify
()
libs/sdk/src/ui/orchestrator-custom.ts:153
↓ 4 callersMethod#prepareForNextRun
* Reset interrupt state and resume all paused user subscriptions. * Called before `run.start()` and `input.respond()` so that * iterators on the
libs/sdk/src/client/stream/index.ts:870
↓ 4 callersMethod#startProjection
( channels: Channel[], onEvent: (event: Event) => void, onDone: () => void )
libs/sdk/src/client/stream/handles/subgraphs.ts:335
↓ 4 callersFunctionHARNESS_TEMPLATE
(view: string)
libs/sdk-angular/src/tests/components/ParallelFanoutReconnectStream.ts:323
↓ 4 callersFunctionXXH3_avalanche64
(input: bigint)
libs/langgraph-core/src/hash.ts:287
↓ 4 callersFunctionXXH3_mix2Accs
(acc: BigUint64Array, key: DataView)
libs/langgraph-core/src/hash.ts:144
↓ 4 callersFunctionXXH3_mix32B
( acc: bigint, data1: DataView, data2: DataView, key: DataView, seed: bigint )
libs/langgraph-core/src/hash.ts:258
↓ 4 callersMethod_addSchema
(stateDefinition: StateDefinitionInit)
libs/langgraph-core/src/graph/state.ts:906
↓ 4 callersFunction_encodeConstructorArgs
( // oxlint-disable-next-line @typescript-eslint/no-unsafe-function-type constructor: Function, method?:
libs/checkpoint/src/serde/jsonplus.ts:91
↓ 4 callersMethod_getChannelsFromSchema
* Convert any supported schema type to a StateDefinition (channel map). * @internal
libs/langgraph-core/src/graph/state.ts:865
↓ 4 callersFunction_getNodePath
(node)
docs/plugins/typedoc/google_analytics/client_script.js:10
↓ 4 callersFunction_indexPendingWrites
( pendingWrites: [string, string, unknown][] | undefined )
libs/langgraph-core/src/pregel/algo.ts:498
↓ 4 callersFunction_isChannelWriteEntry
(x: unknown)
libs/langgraph-core/src/pregel/write.ts:168
↓ 4 callersFunction_isOverwriteValue
( value: unknown )
libs/langgraph-core/src/constants.ts:399
↓ 4 callersFunction_isPassthrough
(x: unknown)
libs/langgraph-core/src/pregel/write.ts:28
↓ 4 callersFunction_localWrite
( // eslint-disable-next-line @typescript-eslint/no-explicit-any commit: (writes: [string, any][]) => any,
libs/langgraph-core/src/pregel/algo.ts:231
↓ 4 callersFunction_readChannels
( channels: Record<string, BaseChannel<Value>> // eslint-disable-next-line @typescript-eslint/no-explicit-
libs/langgraph-core/src/pregel/debug.ts:73
↓ 4 callersFunction_scratchpad
({ pendingWrites, taskId, currentTaskInput, resumeMap, namespaceHash, pendingWritesIndex, }: { p
libs/langgraph-core/src/pregel/algo.ts:1459
↓ 4 callersMethod_updateAsTuples
* Convert the update field to a list of {@link PendingWrite} tuples * @returns List of {@link PendingWrite} tuples of the form `[channelKey, value]
libs/langgraph-core/src/constants.ts:598
↓ 4 callersMethodactivate
* StrictMode-safe lifecycle hook for framework bindings. * * React 18+ `StrictMode` intentionally mounts → unmounts → remounts * components i
libs/sdk/src/stream/controller.ts:1461
↓ 4 callersMethodaddEdge
(_from: string, _to: string)
libs/sdk/src/tests/fixtures/langgraph-mocks.ts:71
↓ 4 callersMethodapplyExecutionNamespace
* Promote a discovered subagent to its execution namespace, derived * from checkpoint history (see `namespace-from-history`). * * Routes thro
libs/sdk/src/stream/discovery/subagents.ts:111
↓ 4 callersFunctionasShallow
(c: ComputedRef<V>)
libs/sdk-vue/src/use-stream.ts:620
↓ 4 callersFunctionassembledMessageToBaseMessage
( assembled: AssembledMessage, role: ExtendedMessageRole, extras: { toolCallId?: string } = {} )
libs/sdk/src/stream/assembled-to-message.ts:119
↓ 4 callersFunctionaudioProjection
( namespace: readonly string[], options?: MediaProjectionOptions )
libs/sdk/src/stream/projections/media.ts:125
↓ 4 callersMethodautoTouch
* Record progress for an automatic signal (write/call/stream/callback). * No-op when `refreshOn === "heartbeat"`, where only explicit heartbeats
libs/langgraph-core/src/pregel/timeout.ts:48
↓ 4 callersFunctionbase64ToBytes
(b64: string)
libs/sdk/src/client/stream/media.ts:168
↓ 4 callersFunctionbindStore
( subscribe: (listener: () => void) => () => void, getSnapshot: () => S )
libs/sdk-angular/src/use-stream.ts:530
↓ 4 callersFunctionbindStore
( subscribe: (listener: () => void) => () => void, getSnapshot: () => S )
libs/sdk-vue/src/use-stream.ts:566
↓ 4 callersMethodbindTools
(tools: BindToolsInput[])
libs/langgraph-supervisor/src/tests/utils.ts:88
↓ 4 callersFunctionblockIndexKey
( activeKey: string, protocolIndex: number, blockType: string )
libs/sdk/src/client/stream/messages.ts:881
↓ 4 callersMethodcancelMany
* Cancel one or more runs. * * @param options Options for cancelling runs. * @returns
libs/sdk/src/client/runs/index.ts:358
↓ 4 callersFunctionchannelsFromCheckpoint
( specs: Cc, checkpoint: ReadonlyCheckpoint, options?: { saver?: BaseCheckpointSaver; config?: RunnableC
libs/langgraph-core/src/channels/base.ts:306
↓ 4 callersFunctionclear
()
libs/sdk/src/utils/stream.ts:142
↓ 4 callersFunctioncloneBlock
(block: T)
libs/sdk/src/client/stream/messages.ts:585
↓ 4 callersMethodcompile
({ checkpointer, store, cache, interruptBefore, interruptAfter, name, description,
libs/langgraph-core/src/graph/state.ts:1394
↓ 4 callersMethodcreateCheckpointTuple
( jsonDoc: any, checkpoint: Checkpoint, pendingWrites?: Array<[string, string, any]> )
libs/checkpoint-redis/src/index.ts:1033
↓ 4 callersFunctioncreateDeterministicToolCallingModel
(options: { toolCallId: string; toolName: string; toolArgs: Record<string, unknown>; finalText: string
libs/sdk-react/src/tests/fixtures/shared.ts:152
↓ 4 callersFunctioncreateHandoffTool
({ agentName, description, }: CreateHandoffToolParams)
libs/langgraph-swarm/src/handoff.ts:61
↓ 4 callersFunctioncreateManager
(onChange?: () => void)
libs/sdk/src/ui/manager.test.ts:1394
↓ 4 callersFunctioncreateMediaProjection
( kind: "audio" | "images" | "video" | "files", namespace: readonly string[], buildAssembler: ( push
libs/sdk/src/stream/projections/media.ts:41
↓ 4 callersFunctioncreateMockEmbedding
(dims: number, options: { asEmpty: boolean })
libs/checkpoint-postgres/src/tests/store.int.test.ts:90
↓ 4 callersFunctiondeepCopy
(obj: T)
libs/checkpoint/src/base.ts:56
↓ 4 callersFunctiondefaultTerminalStatus
()
libs/langgraph-core/src/stream/transformers/lifecycle.ts:430
↓ 4 callersFunctiondeferred
()
libs/sdk/src/stream/submit-coordinator.test.ts:80
↓ 4 callersFunctiondeltaChannelsToSnapshot
( channels: Record<string, BaseChannel>, countersSinceDeltaSnapshot: Record<string, [number, number]> )
libs/langgraph-core/src/channels/base.ts:206
↓ 4 callersFunctiondeterministicStringify
(obj: any)
libs/checkpoint-redis/src/index.ts:1139
↓ 4 callersFunctiondriveAndCollect
( url: string, namespaces: string[][] )
examples/streaming/src/api/multi-namespace.ts:36
↓ 4 callersFunctionelapsedSinceGraphStart
()
examples/streaming/src/subagent-status/remote.ts:42
↓ 4 callersFunctionelapsedSinceGraphStart
()
examples/streaming/src/subagent-status/in-process.ts:36
↓ 4 callersFunctionenqueue
(content: string)
libs/sdk-vue/src/tests/components/QueueStream.tsx:32
↓ 4 callersMethodenqueueOperation
(operation: Operation)
libs/checkpoint/src/store/batch.ts:123
↓ 4 callersFunctionensureAnalyser
(context: AudioContext)
libs/sdk-vue/src/use-audio-player.ts:419
↓ 4 callersFunctionensureContextForElement
()
libs/sdk-vue/src/use-audio-player.ts:448
↓ 4 callersFunctionensureContextForPcm
()
libs/sdk-vue/src/use-audio-player.ts:430
↓ 4 callersMethodensureIndexes
()
libs/checkpoint-redis/src/shallow.ts:718
← previousnext →601–700 of 4,051, ranked by callers