mirror of
https://github.com/aljazceru/mcp-python-sdk.git
synced 2025-12-19 14:54:24 +01:00
fix: Update AnyIO stream creation to use type annotation syntax
This commit is contained in:
@@ -18,12 +18,8 @@ from mcp.types import (
|
|||||||
|
|
||||||
@pytest.mark.anyio
|
@pytest.mark.anyio
|
||||||
async def test_server_session_initialize():
|
async def test_server_session_initialize():
|
||||||
server_to_client_send, server_to_client_receive = anyio.create_memory_object_stream(
|
server_to_client_send, server_to_client_receive = anyio.create_memory_object_stream[JSONRPCMessage](1)
|
||||||
1, JSONRPCMessage
|
client_to_server_send, client_to_server_receive = anyio.create_memory_object_stream[JSONRPCMessage](1)
|
||||||
)
|
|
||||||
client_to_server_send, client_to_server_receive = anyio.create_memory_object_stream(
|
|
||||||
1, JSONRPCMessage
|
|
||||||
)
|
|
||||||
|
|
||||||
async def run_client(client: ClientSession):
|
async def run_client(client: ClientSession):
|
||||||
async for message in client_session.incoming_messages:
|
async for message in client_session.incoming_messages:
|
||||||
|
|||||||
Reference in New Issue
Block a user