MCPcopy Create free account

hub / github.com/TanStack/ai / functions

Functions5,196 in github.com/TanStack/ai

↓ 40 callersMethodfinalizeStream
* 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 callersFunctionmakeCtx
( overrides: Partial<ChatMiddlewareContext> = {}, )
packages/ai/tests/middlewares/fake-otel.ts:249
↓ 40 callersFunctionspyEvents
Create a spy-laden events object for assertions.
packages/ai/tests/stream-processor.test.ts:104
↓ 39 callersFunctionclient
()
packages/ai-sandbox-sprites/tests/client.test.ts:80
↓ 39 callersFunctionsafeCall
(label: string, fn: () => T)
packages/ai/src/middlewares/otel.ts:202
↓ 39 callersMethodstop
()
packages/ai-solid/tests/use-audio-recorder.test.ts:31
↓ 38 callersMethodsubscribe
Subscribe a component to a signal
examples/ts-code-mode-web/src/lib/reports/types.ts:353
↓ 38 callersFunctionwaitForTestComplete
( page: Page, timeout = 15000, expectedToolCount = 1, )
testing/e2e/tests/tools-test/helpers.ts:168
↓ 37 callersFunctiongenerateVideo
( options: VideoCreateOptions<TAdapter, TStream>, )
packages/ai/src/activities/generateVideo/index.ts:298
↓ 37 callersMethodreset
* Clear the result, error, and return to idle state.
packages/ai-client/src/generation-client.ts:315
↓ 36 callersFunctionuseStyles
()
packages/ai-devtools/src/styles/use-styles.ts:3760
↓ 35 callersFunctioncreateClient
(options?: { id?: string threadId?: string connection?: ConnectConnectionAdapter tools?: Reado
packages/ai-client/tests/devtools.test.ts:105
↓ 35 callersFunctioniter
()
packages/ai-devtools/src/components/conversation/IterationCard.tsx:582
↓ 35 callersFunctionrunToIterationStart
( mw: ChatMiddleware, ctx: ChatMiddlewareContext, config: Partial<ChatMiddlewareConfig> = {}, )
packages/ai/tests/middlewares/otel.test.ts:44
↓ 35 callersFunctionuiMessageToModelMessages
( uiMessage: UIMessage, )
packages/ai/src/activities/chat/messages.ts:156
↓ 34 callersFunctionmakeTool
( name: string, opts?: { lazy?: boolean; execute?: (args: any) => any }, )
packages/ai/tests/lazy-tool-manager.test.ts:8
↓ 33 callersFunctiongeminiText
( model: TModel, config?: Omit<GeminiTextConfig, 'apiKey'>, )
packages/ai-gemini/src/adapters/text.ts:976
↓ 33 callersFunctionmkStream
(events: Array<Record<string, unknown>>)
packages/ai-gemini/tests/text-interactions-adapter.test.ts:40
↓ 33 callersFunctionsetupMockResponsesClient
( streamChunks: Array<Record<string, unknown>>, nonStreamResponse?: Record<string, unknown>, )
packages/openai-base/tests/responses-text.test.ts:54
↓ 33 callersFunctiontoServerSentEventsStream
( stream: AsyncIterable<StreamChunk>, abortController?: AbortController, )
packages/ai/src/stream-to-response.ts:50
↓ 33 callersFunctionwaitForResponse
(page: Page, timeout = 15_000)
testing/e2e/tests/helpers.ts:67
↓ 32 callersFunctioncollectChunks
(stream: AsyncIterable<StreamChunk>)
packages/ai-gemini/tests/text-interactions-adapter.test.ts:48
↓ 32 callersFunctioncreateCapability
()
packages/ai/src/activities/chat/middleware/capabilities.ts:114
↓ 32 callersFunctioncreateState
( overrides: Partial<AgentLoopState> = {}, )
packages/ai/tests/agent-loop-strategies.test.ts:10
↓ 32 callersMethodread
(chunk: unknown)
packages/ai-bedrock/tests/adapter.test.ts:28
↓ 32 callersFunctiontoRunErrorRawEvent
(error: unknown)
packages/ai/src/activities/error-payload.ts:91
↓ 31 callersFunctioncreateMockPersistence
( initial?: Array<UIMessage> | null, )
packages/ai-client/tests/test-utils.ts:22
↓ 31 callersFunctioncreatePersistor
* 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 callersMethodenqueue
(request: ClaudeRequest)
examples/ts-group-chat/chat-server/claude-service.ts:102
↓ 31 callersFunctionreject
()
packages/ai-acp/src/permissions.ts:31
↓ 31 callersFunctionurlPart
( value: string, metadata?: MediaInputMetadata, )
packages/ai-fal/tests/image-inputs.test.ts:15
↓ 30 callersFunctionfetch
(request: Request, env: TEnv)
packages/ai-sandbox-cloudflare/src/worker.ts:115
↓ 30 callersMethodshouldIgnoreChunk
Whether a chunk belongs to cleared state and should not be processed.
packages/ai-client/src/client-persistor.ts:215
↓ 29 callersFunctioncreateAdapter
()
packages/ai-gemini/tests/text-interactions-adapter.test.ts:37
↓ 29 callersFunctionmakeServerWithWeatherTool
()
packages/ai-mcp/tests/helpers/in-memory-server.ts:7
↓ 28 callersFunctionchatParamsFromRequestBody
(body: unknown)
packages/ai/src/utilities/chat-params.ts:44
↓ 28 callersFunctionemit
( event: TEvent, payload: Parameters<RealtimeEventHandler<TEvent>>[0], )
packages/ai-grok/src/realtime/adapter.ts:166
↓ 28 callersMethodexecute
(code: string)
packages/ai-isolate-quickjs/src/isolate-context.ts:29
↓ 28 callersFunctionjsonResponse
(body: unknown, status = 200)
packages/ai-grok/tests/video-adapter.test.ts:16
↓ 28 callersFunctionmockFetch
* 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 callersFunctionasChunk
(chunk: Record<string, unknown>)
packages/ai-mistral/src/adapters/text.ts:42
↓ 27 callersFunctioncreateAdapter
()
packages/ai-openrouter/tests/openrouter-responses-adapter.test.ts:29
↓ 27 callersFunctioncreateMockStream
( chunks: Array<Record<string, unknown>>, )
packages/ai/tests/stream-to-response.test.ts:10
↓ 27 callersFunctioncreateSecrets
( values: T, )
packages/ai-sandbox/src/secrets.ts:24
↓ 27 callersFunctiongenerateAudio
( options: AudioActivityOptions<TAdapter, TStream>, )
packages/ai/src/activities/generateAudio/index.ts:130
↓ 27 callersFunctiongenerateTranscription
( options: TranscriptionActivityOptions<TAdapter, TStream>, )
packages/ai/src/activities/generateTranscription/index.ts:160
↓ 27 callersMethodgetResult
()
packages/ai-client/src/generation-client.ts:364
↓ 27 callersMethodgetSessionGenerating
* 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 callersFunctionprovidersFor
(feature: Feature)
testing/e2e/tests/test-matrix.ts:35
↓ 27 callersMethodreload
* Reload the last assistant message
packages/ai-client/src/chat-client.ts:1125
↓ 27 callersMethodsetMessages
* Set the messages array (e.g., from persisted state)
packages/ai/src/activities/chat/stream/processor.ts:212
↓ 26 callersFunctionclientTools
( ...tools: T )
packages/ai-client/src/types.ts:561
↓ 26 callersFunctiondefineSandboxPolicy
(policy: SandboxPolicy)
packages/ai-sandbox/src/policy.ts:37
↓ 26 callersMethodgetError
* Get current error
packages/ai-client/src/chat-client.ts:1420
↓ 26 callersFunctiongetOrCreateConversation
( id: string, type: 'client' | 'server', label: string, )
packages/ai-devtools/src/store/ai-context.tsx:419
↓ 26 callersFunctionnow
()
packages/ai-claude-code/src/stream/translate.ts:107
↓ 26 callersMethodstop
()
packages/ai-client/tests/audio-recorder.test.ts:25
↓ 26 callersMethodtools
( defsOrOptions?: ReadonlyArray<AnyToolDefinition> | ToolsOptions, maybeOptions: ToolsOptions = {},
packages/ai-mcp/src/client.ts:122
↓ 25 callersFunctionadapterWithFetch
* 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 callersFunctioncn
(...inputs: Array<ClassValue>)
examples/ts-react-search/src/utils/cn.ts:5
↓ 25 callersFunctioncreateNodeIsolateDriver
( config: NodeIsolateDriverConfig = {}, )
packages/ai-isolate-node/src/isolate-driver.ts:119
↓ 25 callersFunctioncreateQuickJSIsolateDriver
( config: QuickJSIsolateDriverConfig = {}, )
packages/ai-isolate-quickjs/src/isolate-driver.ts:71
↓ 25 callersMethodemitMessagesChange
* Emit messages change event
packages/ai/src/activities/chat/stream/processor.ts:2014
↓ 25 callersFunctionextractUsageCost
(usage: unknown)
packages/ai-openrouter/src/adapters/cost.ts:86
↓ 25 callersFunctionnow
()
packages/ai-grok-build/src/stream/translate.ts:149
↓ 25 callersFunctionreadString
* 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 callersMethodsend
(message: Body, options?: QueueSendOptions)
examples/sandbox-cloudflare/worker-configuration.d.ts:2363
↓ 24 callersFunctioncreateChatClientOptions
( options: ChatClientOptions<TTools, TContext>, )
packages/ai-client/src/types.ts:583
↓ 24 callersFunctioncreateToolCallChunks
( toolCalls: Array<{ id: string; name: string; arguments: string }>, messageId: string = 'msg-1', model:
packages/ai-client/tests/test-utils.ts:209
↓ 24 callersFunctionsetupMockSdkClient
( streamEvents: Array<Record<string, unknown>>, nonStreamResult?: Record<string, unknown>, )
packages/ai-openrouter/tests/openrouter-responses-adapter.test.ts:54
↓ 23 callersFunctioncreateChat
( options: CreateChatOptions<TTools, TSchema, TContext>, )
packages/ai-svelte/src/create-chat.svelte.ts:54
↓ 23 callersMethodgetIsLoading
* Get loading state
packages/ai-client/src/chat-client.ts:1382
↓ 23 callersFunctionnormalizeSystemPrompts
( // Accept the wide public shape (`SystemPrompt<unknown>`) regardless of the // caller's `TMetadata`. Ada
packages/ai/src/system-prompts.ts:70
↓ 23 callersMethodstop
* Stop the current stream
packages/ai-client/src/chat-client.ts:1154
↓ 22 callersFunctionclickGenerate
(page: Page)
testing/e2e/tests/helpers.ts:188
↓ 22 callersFunctioncreateAdapter
(model: TModel)
packages/ai-anthropic/tests/anthropic-adapter.test.ts:44
↓ 22 callersFunctioncreateUIMessage
( id: string, text: string = 'hello', role: UIMessage['role'] = 'user', )
packages/ai-client/tests/test-utils.ts:9
↓ 22 callersMethoddispose
()
packages/ai-isolate-quickjs/src/isolate-context.ts:151
↓ 22 callersFunctionemit
( event: TEvent, payload: Parameters<RealtimeEventHandler<TEvent>>[0], )
packages/ai-openai/src/realtime/adapter.ts:107
↓ 22 callersFunctiongetEventLog
( page: Page, )
testing/e2e/tests/tools-test/helpers.ts:274
↓ 22 callersMethodmountDevtools
()
packages/ai-client/src/chat-client.ts:438
↓ 22 callersFunctionsafeEmit
(...args)
packages/ai-event-client/src/devtools-middleware.ts:176
↓ 22 callersMethodunsubscribe
Unsubscribe a component from a signal
examples/ts-code-mode-web/src/lib/reports/types.ts:355
↓ 22 callersFunctionwaitForGenerationComplete
(page: Page, timeout = 30_000)
testing/e2e/tests/helpers.ts:205
↓ 21 callersFunctionbootstrapWorkspace
( handle: SandboxHandle, workspace: WorkspaceDefinition, options: { signal?: AbortSignal } = {}, )
packages/ai-sandbox/src/bootstrap.ts:57
↓ 21 callersFunctioncodeExecutionTool
( config: CodeExecutionToolConfig, options: CodeExecutionToolOptions = {}, )
packages/ai-anthropic/src/tools/code-execution-tool.ts:72
↓ 21 callersFunctiondefineWorkspace
( definition: WorkspaceDefinition, )
packages/ai-sandbox/src/workspace.ts:147
↓ 21 callersFunctiongenerateId
(prefix: string)
packages/ai-gemini/src/utils/client.ts:40
↓ 21 callersFunctionmockText
( model: TModel, )
packages/ai/tests/chat-per-model-type-safety.test.ts:121
↓ 21 callersMethodsetAttribute
(name: string, value: string)
examples/sandbox-cloudflare/worker-configuration.d.ts:1837
↓ 21 callersFunctionuseGeneration
( options: Omit<UseGenerationOptions<TInput, TResult>, 'onResult'> & { onResult?: (result: TResult) => T
packages/ai-solid/src/use-generation.ts:106
↓ 21 callersFunctionwarnIfBindingsExposeSecrets
( tools: Array<ToolLike>, options: { handler?: SecretParameterHandler dedupCache?: Set<string> }
packages/ai-code-mode/src/validate-bindings.ts:159
↓ 20 callersMethodcancel
* 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 callersFunctioncreateDeferred
()
packages/ai-client/tests/chat-client.test.ts:44
↓ 20 callersFunctioncreateMistralText
( model: TModel, apiKey: string, config?: Omit<MistralTextConfig, 'apiKey'>, )
packages/ai-mistral/src/adapters/text.ts:1110
↓ 20 callersFunctioncreateOllamaChat
( model: TModel, hostOrConfig?: string | OllamaClientConfig, )
packages/ai-ollama/src/adapters/text.ts:586
↓ 20 callersFunctiondefineSandbox
(config: SandboxConfig)
packages/ai-sandbox/src/sandbox.ts:115
↓ 20 callersFunctionemitCustomEvent
(eventName, value)
packages/ai-sandbox/src/bridge-events.ts:51
↓ 20 callersFunctionevaluateCommand
( command: string, policy: SandboxPolicy | undefined, scripts?: Record<string, string>, )
packages/ai-sandbox/src/policy.ts:93
↓ 20 callersFunctionflush
Let queued microtasks (the native watcher's async classify) settle.
packages/ai-sandbox/tests/watch.test.ts:7
← previousnext →101–200 of 5,196, ranked by callers