(
streamFactory: (
messages: Array<UIMessage> | Array<ModelMessage>,
data?: Record<string, any>,
abortSignal?: AbortSignal,
) => AsyncIterable<StreamChunk>,
)
| 937 | * ``` |
| 938 | */ |
| 939 | export function stream( |
| 940 | streamFactory: ( |
| 941 | messages: Array<UIMessage> | Array<ModelMessage>, |
| 942 | data?: Record<string, any>, |
| 943 | abortSignal?: AbortSignal, |
| 944 | ) => AsyncIterable<StreamChunk>, |
| 945 | ): ConnectConnectionAdapter { |
| 946 | return { |
| 947 | async *connect(messages, data, abortSignal) { |
| 948 | // Pass messages as-is (UIMessages with parts preserved) |
| 949 | // Server-side chat() handles conversion to ModelMessages |
| 950 | yield* streamFactory(messages, data, abortSignal) |
| 951 | }, |
| 952 | } |
| 953 | } |
| 954 | |
| 955 | /** |
| 956 | * Wrap a `ChatFetcher` as a `ConnectConnectionAdapter` so the chat client can |
no outgoing calls
no test coverage detected