✨ [AI]: Add streaming mode with incremental parsing to useGenerateObject

Author: junerver

README.md

@@ -162,7 +162,7 @@ implementation("xyz.junerver.compose:ai:<latest_release>")
 | hook name | description |
 | --------- | ----------- |
 | [useChat](https://github.com/junerver/ComposeHooks/blob/master/app/src/commonMain/kotlin/xyz/junerver/composehooks/example/UseChatExample.kt) | A hook for managing chat conversations with OpenAI-compatible APIs and Anthropic Messages API, supporting streaming responses with typewriter effect. |
-| [useGenerateObject](https://github.com/junerver/ComposeHooks/blob/master/app/src/commonMain/kotlin/xyz/junerver/composehooks/example/UseGenerateObjectExample.kt) | A hook for generating structured data objects from AI responses, supporting multimodal input (text + images). |
+| [useGenerateObject](https://github.com/junerver/ComposeHooks/blob/master/app/src/commonMain/kotlin/xyz/junerver/composehooks/example/UseGenerateObjectExample.kt) | A hook for generating structured data objects from AI responses, supports streaming and incremental object updates. |
 
 **Features:**
 - Streaming responses (SSE) with real-time typewriter effect

README.zh-CN.md

@@ -169,7 +169,7 @@ implementation("xyz.junerver.compose:hai:<latest_release>")
 | Hook 名称 | 描述 |
 | --------- | ---- |
 | [useChat](https://github.com/junerver/ComposeHooks/blob/master/app/src/commonMain/kotlin/xyz/junerver/composehooks/example/UseChatExample.kt) | 用于管理与 OpenAI 兼容 API 和 Anthropic Messages API 聊天对话的 Hook，支持流式响应的打字机效果。 |
-| [useGenerateObject](https://github.com/junerver/ComposeHooks/blob/master/app/src/commonMain/kotlin/xyz/junerver/composehooks/example/UseGenerateObjectExample.kt) | 用于从 AI 响应生成结构化数据对象的 Hook，支持多模态输入（文本 + 图片）。 |
+| [useGenerateObject](https://github.com/junerver/ComposeHooks/blob/master/app/src/commonMain/kotlin/xyz/junerver/composehooks/example/UseGenerateObjectExample.kt) | 用于从 AI 响应生成结构化数据对象的 Hook，支持流式与增量更新对象。 |
 
 **功能特性：**
 - 流式响应 (SSE)，实时打字机效果

ai/src/commonMain/kotlin/xyz/junerver/compose/ai/usegenerateobject/GenerateObjectOptions.kt

@@ -34,6 +34,8 @@ typealias OnObjectFinishCallback<T> = (obj: T, usage: ChatUsage?) -> Unit
  * @property timeout Request timeout duration
  * @property headers Additional HTTP headers to send with requests
  * @property httpEngine Custom HTTP engine (null = use global default)
+ * @property stream Whether to use streaming responses (default true)
+ * @property enableIncrementalParsing Whether to parse partial JSON during streaming (default true)
  * @property enableJsonHealing Enable JSON repair mechanism (default true)
  * @property onResponse Callback when receiving an HTTP response
  * @property onFinish Callback when object generation is complete
@@ -49,6 +51,8 @@ data class GenerateObjectOptions<T> internal constructor(
     override var timeout: Duration = AIOptionsDefaults.DEFAULT_TIMEOUT,
     override var headers: Map<String, String> = AIOptionsDefaults.DEFAULT_HEADERS,
     override var httpEngine: HttpEngine? = null,
+    var stream: Boolean = true,
+    var enableIncrementalParsing: Boolean = true,
     /**
      * Enable JSON repair mechanism, default is true.
      *

ai/src/commonMain/kotlin/xyz/junerver/compose/ai/usegenerateobject/useGenerateObject.kt

@@ -16,6 +16,7 @@ import xyz.junerver.compose.ai.usechat.TextPart
 import xyz.junerver.compose.ai.usechat.UserContentPart
 import xyz.junerver.compose.ai.usechat.useChat
 import xyz.junerver.compose.hooks._useState
+import xyz.junerver.compose.hooks.useEffect
 import xyz.junerver.compose.hooks.useLatestRef
 
 /*
@@ -232,6 +233,8 @@ fun <T : Any> useGenerateObject(
         maxTokens = optionsRef.current.maxTokens
         timeout = optionsRef.current.timeout
         headers = optionsRef.current.headers
+        httpEngine = optionsRef.current.httpEngine
+        stream = optionsRef.current.stream
         onResponse = optionsRef.current.onResponse
 
         onFinish = { message, usage, _ ->
@@ -263,6 +266,22 @@ fun <T : Any> useGenerateObject(
         }
     }
 
+    useEffect(rawJsonState.value, chatHolder.isLoading.value) {
+        val rawJson = rawJsonState.value
+        if (rawJson.isBlank()) return@useEffect
+        if (!chatHolder.isLoading.value) return@useEffect
+        if (!optionsRef.current.stream) return@useEffect
+        if (!optionsRef.current.enableIncrementalParsing) return@useEffect
+
+        try {
+            val cleanJson = healJson(rawJson, optionsRef.current.enableJsonHealing)
+            val obj = defaultJson.decodeFromString(serializerRef.current, cleanJson)
+            parsedObject.value = obj
+        } catch (_: Exception) {
+            // Ignore incremental parse failures during streaming
+        }
+    }
+
     // Combine chat error with parse error
     val combinedError = remember {
         derivedStateOf {