chore(main): release 1.6.0 (#12)

* chore(main): release 1.6.0

* docs: document consumeUIMessageStream in README (#13)

* Initial plan

* docs: add consumeUIMessageStream documentation to README

Co-authored-by: zirkelc <950244+zirkelc@users.noreply.github.com>

* docs: remove advanced example from consumeUIMessageStream section

Co-authored-by: zirkelc <950244+zirkelc@users.noreply.github.com>

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: zirkelc <950244+zirkelc@users.noreply.github.com>

---------

Co-authored-by: Copilot <198982749+Copilot@users.noreply.github.com>
Co-authored-by: zirkelc <950244+zirkelc@users.noreply.github.com>

Author: zirkelc

CHANGELOG.md

@@ -1,5 +1,12 @@
 # Changelog
 
+## [1.6.0](https://github.com/zirkelc/ai-stream-utils/compare/v1.5.0...v1.6.0) (2026-02-11)
+
+
+### Features
+
+* add `consumeUIMessageStream` utility ([#11](https://github.com/zirkelc/ai-stream-utils/issues/11)) ([290f418](https://github.com/zirkelc/ai-stream-utils/commit/290f41827cc4762356a3d3f79f8bc0a16b684564))
+
 ## [1.5.0](https://github.com/zirkelc/ai-stream-utils/compare/v1.4.2...v1.5.0) (2026-01-29)
 
 

README.md

@@ -35,6 +35,7 @@ npm install ai-stream-utils
 | [`mapUIMessageStream`](#mapuimessagestream) | [UIMessageChunk](https://github.com/vercel/ai/blob/main/packages/ai/src/ui-message-stream/ui-message-chunks.ts) | `chunk \| chunk[] \| null` | Transform or filter chunks in real-time (e.g., smooth streaming) |
 | [`flatMapUIMessageStream`](#flatmapuimessagestream) | [UIMessagePart](https://ai-sdk.dev/docs/reference/ai-sdk-core/ui-message#uimessagepart-types) | `part \| part[] \| null` | Buffer until complete, then transform (e.g., redact tool output) |
 | [`filterUIMessageStream`](#filteruimessagestream) | [UIMessageChunk](https://github.com/vercel/ai/blob/main/packages/ai/src/ui-message-stream/ui-message-chunks.ts) | `boolean` | Include/exclude parts by type (e.g., hide reasoning) |
+| [`consumeUIMessageStream`](#consumeuimessagestream) | [UIMessageChunk](https://github.com/vercel/ai/blob/main/packages/ai/src/ui-message-stream/ui-message-chunks.ts) | `Promise<UIMessage>` | Consume entire stream and return final message (e.g., server-side processing) |
 
 ## Usage
 
@@ -113,6 +114,26 @@ const stream = filterUIMessageStream(
 );
 ```
 
+### `consumeUIMessageStream`
+
+The `consumeUIMessageStream` function consumes a UI message stream by fully reading it and returns the final assembled message. This is useful when you need to process the complete message on the server-side without streaming to the client.
+
+```typescript
+import { consumeUIMessageStream } from 'ai-stream-utils';
+
+const result = streamText({
+  model: openai('gpt-4o'),
+  prompt: 'Tell me a joke',
+});
+
+/* Consume the entire stream and get the final message */
+const message = await consumeUIMessageStream(
+  result.toUIMessageStream<MyUIMessage>()
+);
+
+console.log(message.parts); // All parts fully assembled
+```
+
 ## Examples
 
 ### Smooth Streaming
@@ -577,3 +598,11 @@ function excludeParts<UI_MESSAGE extends UIMessage>(
   partTypes: Array<InferUIMessagePartType<UI_MESSAGE>>,
 ): FilterUIMessageStreamPredicate<UI_MESSAGE>
 ```
+
+### `consumeUIMessageStream`
+
+```typescript
+async function consumeUIMessageStream<UI_MESSAGE extends UIMessage>(
+  stream: ReadableStream<InferUIMessageChunk<UI_MESSAGE>>,
+): Promise<UI_MESSAGE>
+```

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ai-stream-utils",
-  "version": "1.5.0",
+  "version": "1.6.0",
   "description": "AI SDK: Filter and transform UI messages while streaming to the client",
   "packageManager": "pnpm@10.0.0",
   "types": "./dist/index.d.mts",