Skip to content

Commit 09988a5

Browse files
Replace SSE test with Pyright/ruff-compliant version
1 parent 6e222b9 commit 09988a5

File tree

1 file changed

+2
-14
lines changed

1 file changed

+2
-14
lines changed

tests/test_sse_client_server.py

Lines changed: 2 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1,31 +1,26 @@
11
import asyncio
2-
from typing import List
2+
from typing import AsyncGenerator, List
33

44
from fastapi import FastAPI
55
from starlette.responses import StreamingResponse
66
import uvicorn
77
from threading import Thread
88
import httpx
9-
109
from mcp.client.sse import aconnect_sse
1110

12-
1311
app = FastAPI()
1412

15-
1613
@app.get("/sse")
1714
async def sse_endpoint() -> StreamingResponse:
18-
async def event_stream() -> asyncio.AsyncGenerator[str, None]:
15+
async def event_stream() -> AsyncGenerator[str, None]:
1916
for i in range(3):
2017
yield f"data: Hello {i+1}\n\n"
2118
await asyncio.sleep(0.1)
2219
return StreamingResponse(event_stream(), media_type="text/event-stream")
2320

24-
2521
def run_mock_server() -> None:
2622
uvicorn.run(app, host="127.0.0.1", port=8012, log_level="warning")
2723

28-
2924
async def test_aconnect_sse_server_response() -> None:
3025
server_thread = Thread(target=run_mock_server, daemon=True)
3126
server_thread.start()
@@ -44,10 +39,3 @@ async def test_aconnect_sse_server_response() -> None:
4439

4540
assert messages == ["Hello 1", "Hello 2", "Hello 3"]
4641
print("\n✅ Test passed! SSE connection via aconnect_sse worked correctly.")
47-
48-
49-
50-
51-
52-
53-

0 commit comments

Comments
 (0)