mirrors/claude-code-sdk-python
1
0
Fork 0
mirror of https://github.com/anthropics/claude-code-sdk-python.git synced 2025-12-23 09:19:52 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Finalize streaming impl

Browse source
This commit is contained in:
Dickson Tsai 2025-07-18 00:16:18 -07:00
parent 4c67548d87
commit f4cff21590
No known key found for this signature in database
1 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/claude_code_sdk/_internal/transport/subprocess_cli.py
View file

@ -157,8 +157,9 @@ class SubprocessCLITransport(Transport):
# Streaming mode: keep stdin open and start streaming task
if self._process.stdin:
self._stdin_stream = TextSendStream(self._process.stdin)
# Start streaming messages to stdin
anyio.start_soon(self._stream_to_stdin)
# Start streaming messages to stdin in background
import asyncio
asyncio.create_task(self._stream_to_stdin())
else:
# String mode: close stdin immediately (backward compatible)
if self._process.stdin:
@ -209,10 +210,8 @@ class SubprocessCLITransport(Transport):
break
await self._stdin_stream.send(json.dumps(message) + "\n")
# Close stdin when done
if self._stdin_stream:
await self._stdin_stream.aclose()
self._stdin_stream = None
# Signal EOF but keep the stream open for control messages
# This matches the TypeScript implementation which calls stdin.end()
except Exception as e:
logger.debug(f"Error streaming to stdin: {e}")
if self._stdin_stream: