fix: address P1 review findings

- _from_full_stream dict chunks: yield full dict instead of extracting
  text, matching the attribute-based path. Fixes structured updates being
  lost for native streaming adapters. Updated _wrapped_stream and
  _text_only_stream to handle dict chunks for accumulation/fallback.

- on_lock_conflict: accept both True and "force" as force-release signal.
  Restores backward compat with callers returning bool while keeping the
  new string-based API. Type updated to accept bool in callable returns.

- fallback stream final edit already fixed in previous commit (c3cbcff).
  The reviewer's worktree was stale.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: patrick-chinchill

src/chat_sdk/chat.py

@@ -1515,7 +1515,7 @@ async def _resolve_lock_conflict(
             # Support both sync and async callables
             if asyncio.iscoroutine(result) or asyncio.isfuture(result):
                 result = await result
-            if result == "force":
+            if result == "force" or result is True:
                 self._logger.info(
                     "on_lock_conflict callback returned 'force', force-releasing lock",
                     {"thread_id": thread_id, "lock_key": lock_key},

src/chat_sdk/thread.py

@@ -513,6 +513,8 @@ async def _wrapped_stream() -> AsyncIterator[str | StreamChunk]:
                 async for chunk in text_stream:
                     if isinstance(chunk, str):
                         accumulated += chunk
+                    elif isinstance(chunk, dict) and chunk.get("type") == "markdown_text":
+                        accumulated += chunk.get("text", "")
                     elif hasattr(chunk, "type") and chunk.type == "markdown_text":
                         accumulated += chunk.text
                     yield chunk
@@ -532,7 +534,9 @@ async def _text_only_stream() -> AsyncIterator[str]:
             async for chunk in text_stream:
                 if isinstance(chunk, str):
                     yield chunk
-                elif hasattr(chunk, "type") and chunk.type == "markdown_text":
+                elif isinstance(chunk, dict) and chunk.get("type") == "markdown_text":
+                    yield chunk.get("text", "")
+                elif hasattr(chunk, "type") and getattr(chunk, "type", None) == "markdown_text":
                     yield chunk.text
                 # Skip non-text chunks in fallback mode
 
@@ -884,7 +888,7 @@ async def _from_full_stream(raw_stream: Any) -> AsyncIterator[str | StreamChunk]
 
             # Pass through known StreamChunk dict types
             if t in ("markdown_text", "task_update", "plan_update"):
-                yield item.get("text", "")
+                yield item
                 continue
 
             if t == "text-delta":

src/chat_sdk/types.py

@@ -40,7 +40,8 @@
 LockScope = Literal["thread", "channel"]
 ConcurrencyStrategy = Literal["drop", "queue", "debounce", "concurrent"]
 OnLockConflict = (
-    Literal["drop", "force"] | Callable[..., Awaitable[Literal["force", "drop"]] | Literal["force", "drop"]]
+    Literal["drop", "force"]
+    | Callable[..., Awaitable[Literal["force", "drop"] | bool] | Literal["force", "drop"] | bool]
 )
 FetchDirection = Literal["forward", "backward"]