Revert streaming to v0.1.1 approach to fix hang

- Use continue instead of break for [DONE] handling
- Remove done flag and explicit outer loop break
- Rely on natural HTTP connection close
- Fix duplicate break in OpenAI provider
- Use conditional stop_reason (tool_use vs end_turn)

Author: Mng-dev-ai

anthropic_bridge/providers/openai/client.py

@@ -327,7 +327,6 @@ async def _stream_response(
                                 "output_tokens": resp_usage.get("output_tokens", 0),
                             }
                             break
-                            break
 
         except Exception as e:
             yield self._sse(
@@ -370,7 +369,7 @@ async def _stream_response(
             {
                 "type": "message_delta",
                 "delta": {
-                    "stop_reason": "end_turn",
+                    "stop_reason": "tool_use" if saw_tool_use else "end_turn",
                     "stop_sequence": None,
                 },
                 "usage": usage,

anthropic_bridge/providers/openrouter/client.py

@@ -182,16 +182,14 @@ async def _stream_openrouter(
                 lines = buffer.split("\n")
                 buffer = lines.pop()
 
-                done = False
                 for line in lines:
                     line = line.strip()
                     if not line or not line.startswith("data: "):
                         continue
 
                     data_str = line[6:]
                     if data_str == "[DONE]":
-                        done = True
-                        break
+                        continue
 
                     try:
                         data = json.loads(data_str)
@@ -399,8 +397,6 @@ async def _stream_openrouter(
                                     await get_reasoning_cache().set(
                                         t["id"], current_reasoning_details.copy()
                                     )
-                if done:
-                    break
 
         if thinking_started:
             yield self._sse(
@@ -435,7 +431,7 @@ async def _stream_openrouter(
             {
                 "type": "message_delta",
                 "delta": {
-                    "stop_reason": "end_turn",
+                    "stop_reason": "tool_use" if saw_tool_use else "end_turn",
                     "stop_sequence": None,
                 },
                 "usage": {

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "anthropic-bridge"
-version = "0.1.27"
+version = "0.1.28"
 description = "Bridge Anthropic API to OpenRouter and OpenAI models."
 license = "MIT"
 requires-python = ">=3.11"