| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -4,9 +4,9 @@ | |||
| 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,7 +8,6 @@ | |||
| 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 | |
| Back | FazBrowse Home | New Git URL |
0 commit comments