Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/TanStack/ai
/ functions
Functions
5,196 in github.com/TanStack/ai
⨍
Functions
5,196
◇
Types & classes
2,311
↓ 40 callers
Method
finalizeStream
* Finalize the stream — complete all pending operations. * * Called when the async iterable ends (stream closed). Acts as the final * safety
packages/ai/src/activities/chat/stream/processor.ts:2027
↓ 40 callers
Function
makeCtx
( overrides: Partial<ChatMiddlewareContext> = {}, )
packages/ai/tests/middlewares/fake-otel.ts:249
↓ 40 callers
Function
spyEvents
Create a spy-laden events object for assertions.
packages/ai/tests/stream-processor.test.ts:104
↓ 39 callers
Function
client
()
packages/ai-sandbox-sprites/tests/client.test.ts:80
↓ 39 callers
Function
safeCall
(label: string, fn: () => T)
packages/ai/src/middlewares/otel.ts:202
↓ 39 callers
Method
stop
()
packages/ai-solid/tests/use-audio-recorder.test.ts:31
↓ 38 callers
Method
subscribe
Subscribe a component to a signal
examples/ts-code-mode-web/src/lib/reports/types.ts:353
↓ 38 callers
Function
waitForTestComplete
( page: Page, timeout = 15000, expectedToolCount = 1, )
testing/e2e/tests/tools-test/helpers.ts:168
↓ 37 callers
Function
generateVideo
( options: VideoCreateOptions<TAdapter, TStream>, )
packages/ai/src/activities/generateVideo/index.ts:298
↓ 37 callers
Method
reset
* Clear the result, error, and return to idle state.
packages/ai-client/src/generation-client.ts:315
↓ 36 callers
Function
useStyles
()
packages/ai-devtools/src/styles/use-styles.ts:3760
↓ 35 callers
Function
createClient
(options?: { id?: string threadId?: string connection?: ConnectConnectionAdapter tools?: Reado
packages/ai-client/tests/devtools.test.ts:105
↓ 35 callers
Function
iter
()
packages/ai-devtools/src/components/conversation/IterationCard.tsx:582
↓ 35 callers
Function
runToIterationStart
( mw: ChatMiddleware, ctx: ChatMiddlewareContext, config: Partial<ChatMiddlewareConfig> = {}, )
packages/ai/tests/middlewares/otel.test.ts:44
↓ 35 callers
Function
uiMessageToModelMessages
( uiMessage: UIMessage, )
packages/ai/src/activities/chat/messages.ts:156
↓ 34 callers
Function
makeTool
( name: string, opts?: { lazy?: boolean; execute?: (args: any) => any }, )
packages/ai/tests/lazy-tool-manager.test.ts:8
↓ 33 callers
Function
geminiText
( model: TModel, config?: Omit<GeminiTextConfig, 'apiKey'>, )
packages/ai-gemini/src/adapters/text.ts:976
↓ 33 callers
Function
mkStream
(events: Array<Record<string, unknown>>)
packages/ai-gemini/tests/text-interactions-adapter.test.ts:40
↓ 33 callers
Function
setupMockResponsesClient
( streamChunks: Array<Record<string, unknown>>, nonStreamResponse?: Record<string, unknown>, )
packages/openai-base/tests/responses-text.test.ts:54
↓ 33 callers
Function
toServerSentEventsStream
( stream: AsyncIterable<StreamChunk>, abortController?: AbortController, )
packages/ai/src/stream-to-response.ts:50
↓ 33 callers
Function
waitForResponse
(page: Page, timeout = 15_000)
testing/e2e/tests/helpers.ts:67
↓ 32 callers
Function
collectChunks
(stream: AsyncIterable<StreamChunk>)
packages/ai-gemini/tests/text-interactions-adapter.test.ts:48
↓ 32 callers
Function
createCapability
()
packages/ai/src/activities/chat/middleware/capabilities.ts:114
↓ 32 callers
Function
createState
( overrides: Partial<AgentLoopState> = {}, )
packages/ai/tests/agent-loop-strategies.test.ts:10
↓ 32 callers
Method
read
(chunk: unknown)
packages/ai-bedrock/tests/adapter.test.ts:28
↓ 32 callers
Function
toRunErrorRawEvent
(error: unknown)
packages/ai/src/activities/error-payload.ts:91
↓ 31 callers
Function
createMockPersistence
( initial?: Array<UIMessage> | null, )
packages/ai-client/tests/test-utils.ts:22
↓ 31 callers
Function
createPersistor
* Build a persistor wired to `adapter` with a spy `applyMessages` callback so * tests can assert what (if anything) gets re-applied to the client.
packages/ai-client/tests/client-persistor.test.ts:30
↓ 31 callers
Method
enqueue
(request: ClaudeRequest)
examples/ts-group-chat/chat-server/claude-service.ts:102
↓ 31 callers
Function
reject
()
packages/ai-acp/src/permissions.ts:31
↓ 31 callers
Function
urlPart
( value: string, metadata?: MediaInputMetadata, )
packages/ai-fal/tests/image-inputs.test.ts:15
↓ 30 callers
Function
fetch
(request: Request, env: TEnv)
packages/ai-sandbox-cloudflare/src/worker.ts:115
↓ 30 callers
Method
shouldIgnoreChunk
Whether a chunk belongs to cleared state and should not be processed.
packages/ai-client/src/client-persistor.ts:215
↓ 29 callers
Function
createAdapter
()
packages/ai-gemini/tests/text-interactions-adapter.test.ts:37
↓ 29 callers
Function
makeServerWithWeatherTool
()
packages/ai-mcp/tests/helpers/in-memory-server.ts:7
↓ 28 callers
Function
chatParamsFromRequestBody
(body: unknown)
packages/ai/src/utilities/chat-params.ts:44
↓ 28 callers
Function
emit
( event: TEvent, payload: Parameters<RealtimeEventHandler<TEvent>>[0], )
packages/ai-grok/src/realtime/adapter.ts:166
↓ 28 callers
Method
execute
(code: string)
packages/ai-isolate-quickjs/src/isolate-context.ts:29
↓ 28 callers
Function
jsonResponse
(body: unknown, status = 200)
packages/ai-grok/tests/video-adapter.test.ts:16
↓ 28 callers
Function
mockFetch
* A `vi.fn` fetch stub with the real fetch parameter list, so call * assertions (`mock.calls[0]`) are typed as `[input, init?]`.
packages/ai-grok/tests/video-adapter.test.ts:27
↓ 27 callers
Function
asChunk
(chunk: Record<string, unknown>)
packages/ai-mistral/src/adapters/text.ts:42
↓ 27 callers
Function
createAdapter
()
packages/ai-openrouter/tests/openrouter-responses-adapter.test.ts:29
↓ 27 callers
Function
createMockStream
( chunks: Array<Record<string, unknown>>, )
packages/ai/tests/stream-to-response.test.ts:10
↓ 27 callers
Function
createSecrets
( values: T, )
packages/ai-sandbox/src/secrets.ts:24
↓ 27 callers
Function
generateAudio
( options: AudioActivityOptions<TAdapter, TStream>, )
packages/ai/src/activities/generateAudio/index.ts:130
↓ 27 callers
Function
generateTranscription
( options: TranscriptionActivityOptions<TAdapter, TStream>, )
packages/ai/src/activities/generateTranscription/index.ts:160
↓ 27 callers
Method
getResult
()
packages/ai-client/src/generation-client.ts:364
↓ 27 callers
Method
getSessionGenerating
* Whether the shared session is actively generating. * Derived from stream run events (RUN_STARTED / RUN_FINISHED / RUN_ERROR). * Unlike `isLoad
packages/ai-client/src/chat-client.ts:1413
↓ 27 callers
Function
providersFor
(feature: Feature)
testing/e2e/tests/test-matrix.ts:35
↓ 27 callers
Method
reload
* Reload the last assistant message
packages/ai-client/src/chat-client.ts:1125
↓ 27 callers
Method
setMessages
* Set the messages array (e.g., from persisted state)
packages/ai/src/activities/chat/stream/processor.ts:212
↓ 26 callers
Function
clientTools
( ...tools: T )
packages/ai-client/src/types.ts:561
↓ 26 callers
Function
defineSandboxPolicy
(policy: SandboxPolicy)
packages/ai-sandbox/src/policy.ts:37
↓ 26 callers
Method
getError
* Get current error
packages/ai-client/src/chat-client.ts:1420
↓ 26 callers
Function
getOrCreateConversation
( id: string, type: 'client' | 'server', label: string, )
packages/ai-devtools/src/store/ai-context.tsx:419
↓ 26 callers
Function
now
()
packages/ai-claude-code/src/stream/translate.ts:107
↓ 26 callers
Method
stop
()
packages/ai-client/tests/audio-recorder.test.ts:25
↓ 26 callers
Method
tools
( defsOrOptions?: ReadonlyArray<AnyToolDefinition> | ToolsOptions, maybeOptions: ToolsOptions = {},
packages/ai-mcp/src/client.ts:122
↓ 25 callers
Function
adapterWithFetch
* Builds an adapter whose HTTP layer is the provided mock — injected via * the adapter config's `fetch` seam, so no globals are touched.
packages/ai-grok/tests/video-adapter.test.ts:37
↓ 25 callers
Function
cn
(...inputs: Array<ClassValue>)
examples/ts-react-search/src/utils/cn.ts:5
↓ 25 callers
Function
createNodeIsolateDriver
( config: NodeIsolateDriverConfig = {}, )
packages/ai-isolate-node/src/isolate-driver.ts:119
↓ 25 callers
Function
createQuickJSIsolateDriver
( config: QuickJSIsolateDriverConfig = {}, )
packages/ai-isolate-quickjs/src/isolate-driver.ts:71
↓ 25 callers
Method
emitMessagesChange
* Emit messages change event
packages/ai/src/activities/chat/stream/processor.ts:2014
↓ 25 callers
Function
extractUsageCost
(usage: unknown)
packages/ai-openrouter/src/adapters/cost.ts:86
↓ 25 callers
Function
now
()
packages/ai-grok-build/src/stream/translate.ts:149
↓ 25 callers
Function
readString
* Runtime-checked field readers for untyped server events. Replace the * drive-by `event.X as string` / `event.X as Record<string, unknown>` casts *
packages/ai-grok/src/realtime/adapter.ts:25
↓ 25 callers
Method
send
(message: Body, options?: QueueSendOptions)
examples/sandbox-cloudflare/worker-configuration.d.ts:2363
↓ 24 callers
Function
createChatClientOptions
( options: ChatClientOptions<TTools, TContext>, )
packages/ai-client/src/types.ts:583
↓ 24 callers
Function
createToolCallChunks
( toolCalls: Array<{ id: string; name: string; arguments: string }>, messageId: string = 'msg-1', model:
packages/ai-client/tests/test-utils.ts:209
↓ 24 callers
Function
setupMockSdkClient
( streamEvents: Array<Record<string, unknown>>, nonStreamResult?: Record<string, unknown>, )
packages/ai-openrouter/tests/openrouter-responses-adapter.test.ts:54
↓ 23 callers
Function
createChat
( options: CreateChatOptions<TTools, TSchema, TContext>, )
packages/ai-svelte/src/create-chat.svelte.ts:54
↓ 23 callers
Method
getIsLoading
* Get loading state
packages/ai-client/src/chat-client.ts:1382
↓ 23 callers
Function
normalizeSystemPrompts
( // Accept the wide public shape (`SystemPrompt<unknown>`) regardless of the // caller's `TMetadata`. Ada
packages/ai/src/system-prompts.ts:70
↓ 23 callers
Method
stop
* Stop the current stream
packages/ai-client/src/chat-client.ts:1154
↓ 22 callers
Function
clickGenerate
(page: Page)
testing/e2e/tests/helpers.ts:188
↓ 22 callers
Function
createAdapter
(model: TModel)
packages/ai-anthropic/tests/anthropic-adapter.test.ts:44
↓ 22 callers
Function
createUIMessage
( id: string, text: string = 'hello', role: UIMessage['role'] = 'user', )
packages/ai-client/tests/test-utils.ts:9
↓ 22 callers
Method
dispose
()
packages/ai-isolate-quickjs/src/isolate-context.ts:151
↓ 22 callers
Function
emit
( event: TEvent, payload: Parameters<RealtimeEventHandler<TEvent>>[0], )
packages/ai-openai/src/realtime/adapter.ts:107
↓ 22 callers
Function
getEventLog
( page: Page, )
testing/e2e/tests/tools-test/helpers.ts:274
↓ 22 callers
Method
mountDevtools
()
packages/ai-client/src/chat-client.ts:438
↓ 22 callers
Function
safeEmit
(...args)
packages/ai-event-client/src/devtools-middleware.ts:176
↓ 22 callers
Method
unsubscribe
Unsubscribe a component from a signal
examples/ts-code-mode-web/src/lib/reports/types.ts:355
↓ 22 callers
Function
waitForGenerationComplete
(page: Page, timeout = 30_000)
testing/e2e/tests/helpers.ts:205
↓ 21 callers
Function
bootstrapWorkspace
( handle: SandboxHandle, workspace: WorkspaceDefinition, options: { signal?: AbortSignal } = {}, )
packages/ai-sandbox/src/bootstrap.ts:57
↓ 21 callers
Function
codeExecutionTool
( config: CodeExecutionToolConfig, options: CodeExecutionToolOptions = {}, )
packages/ai-anthropic/src/tools/code-execution-tool.ts:72
↓ 21 callers
Function
defineWorkspace
( definition: WorkspaceDefinition, )
packages/ai-sandbox/src/workspace.ts:147
↓ 21 callers
Function
generateId
(prefix: string)
packages/ai-gemini/src/utils/client.ts:40
↓ 21 callers
Function
mockText
( model: TModel, )
packages/ai/tests/chat-per-model-type-safety.test.ts:121
↓ 21 callers
Method
setAttribute
(name: string, value: string)
examples/sandbox-cloudflare/worker-configuration.d.ts:1837
↓ 21 callers
Function
useGeneration
( options: Omit<UseGenerationOptions<TInput, TResult>, 'onResult'> & { onResult?: (result: TResult) => T
packages/ai-solid/src/use-generation.ts:106
↓ 21 callers
Function
warnIfBindingsExposeSecrets
( tools: Array<ToolLike>, options: { handler?: SecretParameterHandler dedupCache?: Set<string> }
packages/ai-code-mode/src/validate-bindings.ts:159
↓ 20 callers
Method
cancel
* The **`cancel()`** method of the ReadableStream interface returns a Promise that resolves when the stream is canceled. * * [MDN Reference](htt
examples/sandbox-cloudflare/worker-configuration.d.ts:2723
↓ 20 callers
Function
createDeferred
()
packages/ai-client/tests/chat-client.test.ts:44
↓ 20 callers
Function
createMistralText
( model: TModel, apiKey: string, config?: Omit<MistralTextConfig, 'apiKey'>, )
packages/ai-mistral/src/adapters/text.ts:1110
↓ 20 callers
Function
createOllamaChat
( model: TModel, hostOrConfig?: string | OllamaClientConfig, )
packages/ai-ollama/src/adapters/text.ts:586
↓ 20 callers
Function
defineSandbox
(config: SandboxConfig)
packages/ai-sandbox/src/sandbox.ts:115
↓ 20 callers
Function
emitCustomEvent
(eventName, value)
packages/ai-sandbox/src/bridge-events.ts:51
↓ 20 callers
Function
evaluateCommand
( command: string, policy: SandboxPolicy | undefined, scripts?: Record<string, string>, )
packages/ai-sandbox/src/policy.ts:93
↓ 20 callers
Function
flush
Let queued microtasks (the native watcher's async classify) settle.
packages/ai-sandbox/tests/watch.test.ts:7
← previous
next →
101–200 of 5,196, ranked by callers