File tree 2 files changed +3
-3
lines changed
2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change 4
4
from typing import AsyncGenerator
5
5
6
6
import anyio
7
+ from anyio .streams .memory import MemoryObjectReceiveStream , MemoryObjectSendStream
7
8
from pydantic import ValidationError
8
9
from websockets .asyncio .client import connect as ws_connect
9
- from anyio .streams .memory import MemoryObjectReceiveStream , MemoryObjectSendStream
10
10
from websockets .typing import Subprotocol
11
11
12
12
import mcp .types as types
@@ -59,7 +59,8 @@ async def ws_reader():
59
59
60
60
async def ws_writer ():
61
61
"""
62
- Reads JSON-RPC messages from write_stream_reader and sends them to the server.
62
+ Reads JSON-RPC messages from write_stream_reader and
63
+ sends them to the server.
63
64
"""
64
65
async with write_stream_reader :
65
66
async for message in write_stream_reader :
Original file line number Diff line number Diff line change 8
8
import uvicorn
9
9
from pydantic import AnyUrl
10
10
from starlette .applications import Starlette
11
- from starlette .requests import Request
12
11
from starlette .routing import WebSocketRoute
13
12
14
13
from mcp .client .session import ClientSession
You can’t perform that action at this time.
0 commit comments