fix: emit tool-input-end before tool-call in multi-chunk and flush paths

.changeset/fix-tool-input-end-streaming.md

@@ -0,0 +1,9 @@
+---
+"@openrouter/ai-sdk-provider": patch
+---
+
+Fix missing `tool-input-end` event in multi-chunk and flush tool call streaming paths
+
+The multi-chunk tool call merge path and the flush path for unsent tool calls were missing the `tool-input-end` event before emitting `tool-call`. This diverged from the stream event protocol used by `@ai-sdk/openai`, which consistently emits `tool-input-start → tool-input-delta → tool-input-end → tool-call`.
+
+The flush path for unsent tool calls also now emits the full `tool-input-start → tool-input-delta → tool-input-end` sequence before `tool-call`, matching the reference implementation.

e2e/issues/issue-413-tool-input-end-streaming.test.ts

@@ -0,0 +1,95 @@
+/**
+ * Regression test for GitHub issue #413
+ * https://github.com/OpenRouterTeam/ai-sdk-provider/issues/413
+ *
+ * Issue: "Tool call events are buffered until stream ends (flush) causing
+ * perceived streaming delay"
+ *
+ * The reporter observed that streaming tool calls with @openrouter/ai-sdk-provider
+ * were missing `tool-input-end` events in the multi-chunk tool call path, diverging
+ * from the protocol used by @ai-sdk/openai. The single-chunk path correctly emitted
+ * tool-input-start -> tool-input-delta -> tool-input-end -> tool-call, but the
+ * multi-chunk merge path skipped tool-input-end before tool-call.
+ *
+ * This test verifies that streamText with tool calls emits the complete event
+ * sequence including tool-input-end before tool-call.
+ */
+import { streamText, tool } from 'ai';
+import { describe, expect, it, vi } from 'vitest';
+import { z } from 'zod/v4';
+import { createOpenRouter } from '@/src';
+
+vi.setConfig({
+  testTimeout: 60_000,
+});
+
+describe('Issue #413: Tool call streaming should emit tool-input-end before tool-call', () => {
+  const openrouter = createOpenRouter({
+    apiKey: process.env.OPENROUTER_API_KEY,
+    baseUrl: `${process.env.OPENROUTER_API_BASE}/api/v1`,
+  });
+
+  it('should emit tool-input-end before tool-call with openai/gpt-4.1-nano', async () => {
+    const getWeather = tool({
+      description: 'Gets the current weather for a given city',
+      inputSchema: z.object({
+        city: z.string().describe('The city to get weather for'),
+      }),
+      execute: async ({ city }) => {
+        return { city, temperature: 72, condition: 'sunny' };
+      },
+    });
+
+    const response = streamText({
+      model: openrouter('openai/gpt-4.1-nano'),
+      prompt: 'What is the weather in San Francisco? Use the getWeather tool.',
+      tools: { getWeather },
+      toolChoice: 'required',
+    });
+
+    const events: string[] = [];
+    for await (const event of response.fullStream) {
+      events.push(event.type);
+    }
+
+    expect(events).toContain('tool-input-start');
+    expect(events).toContain('tool-input-end');
+    expect(events).toContain('tool-call');
+
+    const toolInputEndIndex = events.indexOf('tool-input-end');
+    const toolCallIndex = events.indexOf('tool-call');
+    expect(toolInputEndIndex).toBeLessThan(toolCallIndex);
+  });
+
+  it('should emit tool-input-end before tool-call with openai/gpt-4.1-mini', async () => {
+    const getWeather = tool({
+      description: 'Gets the current weather for a given city',
+      inputSchema: z.object({
+        city: z.string().describe('The city to get weather for'),
+      }),
+      execute: async ({ city }) => {
+        return { city, temperature: 72, condition: 'sunny' };
+      },
+    });
+
+    const response = streamText({
+      model: openrouter('openai/gpt-4.1-mini'),
+      prompt: 'What is the weather in San Francisco? Use the getWeather tool.',
+      tools: { getWeather },
+      toolChoice: 'required',
+    });
+
+    const events: string[] = [];
+    for await (const event of response.fullStream) {
+      events.push(event.type);
+    }
+
+    expect(events).toContain('tool-input-start');
+    expect(events).toContain('tool-input-end');
+    expect(events).toContain('tool-call');
+
+    const toolInputEndIndex = events.indexOf('tool-input-end');
+    const toolCallIndex = events.indexOf('tool-call');
+    expect(toolInputEndIndex).toBeLessThan(toolCallIndex);
+  });
+});

src/chat/index.test.ts

@@ -1626,6 +1626,10 @@ describe('doStream', () => {
         id: 'call_O17Uplv4lJvD6DVdIvFFeRMw',
         delta: '"}',
       },
+      {
+        type: 'tool-input-end',
+        id: 'call_O17Uplv4lJvD6DVdIvFFeRMw',
+      },
       {
         type: 'tool-call',
         toolCallId: 'call_O17Uplv4lJvD6DVdIvFFeRMw',

src/chat/index.ts

@@ -992,6 +992,11 @@ export class OpenRouterChatLanguageModel implements LanguageModelV3 {
                   toolCall.function?.arguments != null &&
                   isParsableJson(toolCall.function.arguments)
                 ) {
+                  controller.enqueue({
+                    type: 'tool-input-end',
+                    id: toolCall.id,
+                  });
+
                   // Only attach reasoning_details to the first tool call to avoid
                   // duplicating thinking blocks for parallel tool calls (Claude)
                   controller.enqueue({
@@ -1045,16 +1050,36 @@ export class OpenRouterChatLanguageModel implements LanguageModelV3 {
             if (finishReason.unified === 'tool-calls') {
               for (const toolCall of toolCalls) {
                 if (toolCall && !toolCall.sent) {
+                  const toolInput = isParsableJson(toolCall.function.arguments)
+                    ? toolCall.function.arguments
+                    : '{}';
+
+                  if (!toolCall.inputStarted) {
+                    controller.enqueue({
+                      type: 'tool-input-start',
+                      id: toolCall.id,
+                      toolName: toolCall.function.name,
+                    });
+                  }
+
+                  controller.enqueue({
+                    type: 'tool-input-delta',
+                    id: toolCall.id,
+                    delta: toolInput,
+                  });
+
+                  controller.enqueue({
+                    type: 'tool-input-end',
+                    id: toolCall.id,
+                  });
+
                   // Only attach reasoning_details to the first tool call to avoid
                   // duplicating thinking blocks for parallel tool calls (Claude)
                   controller.enqueue({
                     type: 'tool-call',
                     toolCallId: toolCall.id ?? generateId(),
                     toolName: toolCall.function.name,
-                    // Coerce invalid arguments to an empty JSON object
-                    input: isParsableJson(toolCall.function.arguments)
-                      ? toolCall.function.arguments
-                      : '{}',
+                    input: toolInput,
                     providerMetadata: !reasoningDetailsAttachedToToolCall
                       ? {
                           openrouter: {