File tree Expand file tree Collapse file tree 2 files changed +6
-4
lines changed
Expand file tree Collapse file tree 2 files changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -240,7 +240,9 @@ async def send_request(
240240
241241 # TODO: Support progress callbacks
242242
243- await self ._write_stream .send (SessionMessage (message = JSONRPCMessage (jsonrpc_request )))
243+ await self ._write_stream .send (
244+ SessionMessage (message = JSONRPCMessage (jsonrpc_request ))
245+ )
244246
245247 # request read timeout takes precedence over session read timeout
246248 timeout = None
Original file line number Diff line number Diff line change 88from mcp .server .lowlevel import NotificationOptions
99from mcp .server .models import InitializationOptions
1010from mcp .server .session import ServerSession
11+ from mcp .shared .message import SessionMessage
1112from mcp .shared .session import RequestResponder
1213from mcp .types import (
1314 ClientResult ,
14- JSONRPCMessage ,
1515 ServerNotification ,
1616 ServerRequest ,
1717 Tool ,
@@ -46,10 +46,10 @@ async def list_tools():
4646 ]
4747
4848 server_to_client_send , server_to_client_receive = anyio .create_memory_object_stream [
49- JSONRPCMessage
49+ SessionMessage
5050 ](10 )
5151 client_to_server_send , client_to_server_receive = anyio .create_memory_object_stream [
52- JSONRPCMessage
52+ SessionMessage
5353 ](10 )
5454
5555 # Message handler for client
You can’t perform that action at this time.
0 commit comments