We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 95b44fb commit 97ea065Copy full SHA for 97ea065
src/mcp/server/stdio.py
@@ -54,8 +54,9 @@ async def stdio_server(
54
write_stream: MemoryObjectSendStream[SessionMessage]
55
write_stream_reader: MemoryObjectReceiveStream[SessionMessage]
56
57
- read_stream_writer, read_stream = anyio.create_memory_object_stream(0)
58
- write_stream, write_stream_reader = anyio.create_memory_object_stream(0)
+ # FIXED: Changed from 0 to 10 to create buffered streams
+ read_stream_writer, read_stream = anyio.create_memory_object_stream(10)
59
+ write_stream, write_stream_reader = anyio.create_memory_object_stream(10)
60
61
async def stdin_reader():
62
try:
0 commit comments