You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: docs/reference/classes/StreamProcessor.md
+20-20Lines changed: 20 additions & 20 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -5,7 +5,7 @@ title: StreamProcessor
5
5
6
6
# Class: StreamProcessor
7
7
8
-
Defined in: [activities/chat/stream/processor.ts:114](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L114)
8
+
Defined in: [activities/chat/stream/processor.ts:115](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L115)
9
9
10
10
StreamProcessor - State machine for processing AI response streams
11
11
@@ -31,7 +31,7 @@ Tool call completion is detected when:
31
31
newStreamProcessor(options): StreamProcessor;
32
32
```
33
33
34
-
Defined in: [activities/chat/stream/processor.ts:142](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L142)
34
+
Defined in: [activities/chat/stream/processor.ts:143](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L143)
35
35
36
36
#### Parameters
37
37
@@ -51,7 +51,7 @@ Defined in: [activities/chat/stream/processor.ts:142](https://github.com/TanStac
Defined in: [activities/chat/stream/processor.ts:255](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L255)
54
+
Defined in: [activities/chat/stream/processor.ts:256](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L256)
55
55
56
56
Add an approval response (called by client after handling onApprovalRequest)
57
57
@@ -80,7 +80,7 @@ addToolResult(
80
80
error?):void;
81
81
```
82
82
83
-
Defined in: [activities/chat/stream/processor.ts:211](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L211)
83
+
Defined in: [activities/chat/stream/processor.ts:212](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L212)
84
84
85
85
Add a tool result (called by client after handling onToolCall)
86
86
@@ -110,7 +110,7 @@ Add a tool result (called by client after handling onToolCall)
110
110
addUserMessage(content): UIMessage;
111
111
```
112
112
113
-
Defined in: [activities/chat/stream/processor.ts:169](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L169)
113
+
Defined in: [activities/chat/stream/processor.ts:170](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L170)
114
114
115
115
Add a user message to the conversation
116
116
@@ -132,7 +132,7 @@ Add a user message to the conversation
132
132
areAllToolsComplete(): boolean;
133
133
```
134
134
135
-
Defined in: [activities/chat/stream/processor.ts:286](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L286)
135
+
Defined in: [activities/chat/stream/processor.ts:287](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L287)
136
136
137
137
Check if all tool calls in the last assistant message are complete
138
138
Useful for auto-continue logic
@@ -149,7 +149,7 @@ Useful for auto-continue logic
149
149
clearMessages(): void;
150
150
```
151
151
152
-
Defined in: [activities/chat/stream/processor.ts:318](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L318)
152
+
Defined in: [activities/chat/stream/processor.ts:331](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L331)
153
153
154
154
Clear all messages
155
155
@@ -165,7 +165,7 @@ Clear all messages
165
165
finalizeStream(): void;
166
166
```
167
167
168
-
Defined in: [activities/chat/stream/processor.ts:814](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L814)
168
+
Defined in: [activities/chat/stream/processor.ts:827](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L827)
169
169
170
170
Finalize the stream - complete all pending operations
171
171
@@ -181,7 +181,7 @@ Finalize the stream - complete all pending operations
181
181
getMessages(): UIMessage[];
182
182
```
183
183
184
-
Defined in: [activities/chat/stream/processor.ts:278](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L278)
184
+
Defined in: [activities/chat/stream/processor.ts:279](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L279)
185
185
186
186
Get current messages
187
187
@@ -197,7 +197,7 @@ Get current messages
197
197
getRecording(): ChunkRecording|null;
198
198
```
199
199
200
-
Defined in: [activities/chat/stream/processor.ts:893](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L893)
200
+
Defined in: [activities/chat/stream/processor.ts:906](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L906)
201
201
202
202
Get the current recording
203
203
@@ -213,7 +213,7 @@ Get the current recording
213
213
getState(): ProcessorState;
214
214
```
215
215
216
-
Defined in: [activities/chat/stream/processor.ts:866](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L866)
216
+
Defined in: [activities/chat/stream/processor.ts:879](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L879)
217
217
218
218
Get current processor state
219
219
@@ -229,7 +229,7 @@ Get current processor state
229
229
process(stream): Promise<ProcessorResult>;
230
230
```
231
231
232
-
Defined in: [activities/chat/stream/processor.ts:331](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L331)
232
+
Defined in: [activities/chat/stream/processor.ts:344](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L344)
233
233
234
234
Process a stream and emit events through handlers
235
235
@@ -251,7 +251,7 @@ Process a stream and emit events through handlers
251
251
processChunk(chunk): void;
252
252
```
253
253
254
-
Defined in: [activities/chat/stream/processor.ts:359](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L359)
254
+
Defined in: [activities/chat/stream/processor.ts:372](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L372)
255
255
256
256
Process a single chunk from the stream
257
257
@@ -273,7 +273,7 @@ Process a single chunk from the stream
273
273
removeMessagesAfter(index): void;
274
274
```
275
275
276
-
Defined in: [activities/chat/stream/processor.ts:310](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L310)
276
+
Defined in: [activities/chat/stream/processor.ts:323](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L323)
277
277
278
278
Remove messages after a certain index (for reload/retry)
279
279
@@ -295,7 +295,7 @@ Remove messages after a certain index (for reload/retry)
295
295
reset(): void;
296
296
```
297
297
298
-
Defined in: [activities/chat/stream/processor.ts:916](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L916)
298
+
Defined in: [activities/chat/stream/processor.ts:929](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L929)
299
299
300
300
Full reset (including messages)
301
301
@@ -311,7 +311,7 @@ Full reset (including messages)
311
311
setMessages(messages): void;
312
312
```
313
313
314
-
Defined in: [activities/chat/stream/processor.ts:161](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L161)
314
+
Defined in: [activities/chat/stream/processor.ts:162](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L162)
315
315
316
316
Set the messages array (e.g., from persisted state)
317
317
@@ -333,7 +333,7 @@ Set the messages array (e.g., from persisted state)
333
333
startAssistantMessage(): string;
334
334
```
335
335
336
-
Defined in: [activities/chat/stream/processor.ts:187](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L187)
336
+
Defined in: [activities/chat/stream/processor.ts:188](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L188)
337
337
338
338
Start streaming a new assistant message
339
339
Returns the message ID
@@ -350,7 +350,7 @@ Returns the message ID
350
350
startRecording(): void;
351
351
```
352
352
353
-
Defined in: [activities/chat/stream/processor.ts:880](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L880)
353
+
Defined in: [activities/chat/stream/processor.ts:893](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L893)
Defined in: [activities/chat/stream/processor.ts:267](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L267)
372
+
Defined in: [activities/chat/stream/processor.ts:268](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L268)
373
373
374
374
Get the conversation as ModelMessages (for sending to LLM)
375
375
@@ -388,7 +388,7 @@ Get the conversation as ModelMessages (for sending to LLM)
Defined in: [activities/chat/stream/processor.ts:925](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L925)
391
+
Defined in: [activities/chat/stream/processor.ts:938](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L938)
Copy file name to clipboardExpand all lines: docs/reference/functions/createReplayStream.md
+1-1Lines changed: 1 addition & 1 deletion
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -9,7 +9,7 @@ title: createReplayStream
9
9
function createReplayStream(recording):AsyncIterable<AGUIEvent>;
10
10
```
11
11
12
-
Defined in: [activities/chat/stream/processor.ts:937](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L937)
12
+
Defined in: [activities/chat/stream/processor.ts:950](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L950)
Copy file name to clipboardExpand all lines: docs/reference/interfaces/StreamProcessorEvents.md
+10-10Lines changed: 10 additions & 10 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -5,7 +5,7 @@ title: StreamProcessorEvents
5
5
6
6
# Interface: StreamProcessorEvents
7
7
8
-
Defined in: [activities/chat/stream/processor.ts:48](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L48)
8
+
Defined in: [activities/chat/stream/processor.ts:49](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L49)
9
9
10
10
Events emitted by the StreamProcessor
11
11
@@ -17,7 +17,7 @@ Events emitted by the StreamProcessor
17
17
optionalonApprovalRequest: (args) =>void;
18
18
```
19
19
20
-
Defined in: [activities/chat/stream/processor.ts:63](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L63)
20
+
Defined in: [activities/chat/stream/processor.ts:64](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L64)
21
21
22
22
#### Parameters
23
23
@@ -51,7 +51,7 @@ Defined in: [activities/chat/stream/processor.ts:63](https://github.com/TanStack
51
51
optionalonError: (error) =>void;
52
52
```
53
53
54
-
Defined in: [activities/chat/stream/processor.ts:55](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L55)
54
+
Defined in: [activities/chat/stream/processor.ts:56](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L56)
55
55
56
56
#### Parameters
57
57
@@ -71,7 +71,7 @@ Defined in: [activities/chat/stream/processor.ts:55](https://github.com/TanStack
71
71
optionalonMessagesChange: (messages) =>void;
72
72
```
73
73
74
-
Defined in: [activities/chat/stream/processor.ts:50](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L50)
74
+
Defined in: [activities/chat/stream/processor.ts:51](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L51)
75
75
76
76
#### Parameters
77
77
@@ -91,7 +91,7 @@ Defined in: [activities/chat/stream/processor.ts:50](https://github.com/TanStack
91
91
optionalonStreamEnd: (message) =>void;
92
92
```
93
93
94
-
Defined in: [activities/chat/stream/processor.ts:54](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L54)
94
+
Defined in: [activities/chat/stream/processor.ts:55](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L55)
95
95
96
96
#### Parameters
97
97
@@ -111,7 +111,7 @@ Defined in: [activities/chat/stream/processor.ts:54](https://github.com/TanStack
111
111
optionalonStreamStart: () =>void;
112
112
```
113
113
114
-
Defined in: [activities/chat/stream/processor.ts:53](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L53)
114
+
Defined in: [activities/chat/stream/processor.ts:54](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L54)
115
115
116
116
#### Returns
117
117
@@ -125,7 +125,7 @@ Defined in: [activities/chat/stream/processor.ts:53](https://github.com/TanStack
Defined in: [activities/chat/stream/processor.ts:71](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L71)
128
+
Defined in: [activities/chat/stream/processor.ts:72](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L72)
129
129
130
130
#### Parameters
131
131
@@ -149,7 +149,7 @@ Defined in: [activities/chat/stream/processor.ts:71](https://github.com/TanStack
Defined in: [activities/chat/stream/processor.ts:78](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L78)
152
+
Defined in: [activities/chat/stream/processor.ts:79](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L79)
153
153
154
154
#### Parameters
155
155
@@ -173,7 +173,7 @@ Defined in: [activities/chat/stream/processor.ts:78](https://github.com/TanStack
173
173
optionalonToolCall: (args) =>void;
174
174
```
175
175
176
-
Defined in: [activities/chat/stream/processor.ts:58](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L58)
176
+
Defined in: [activities/chat/stream/processor.ts:59](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L59)
177
177
178
178
#### Parameters
179
179
@@ -203,7 +203,7 @@ Defined in: [activities/chat/stream/processor.ts:58](https://github.com/TanStack
Defined in: [activities/chat/stream/processor.ts:72](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L72)
206
+
Defined in: [activities/chat/stream/processor.ts:73](https://github.com/TanStack/ai/blob/main/packages/typescript/ai/src/activities/chat/stream/processor.ts#L73)
0 commit comments