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 @@ -241,7 +241,9 @@ async def send_request(
241241
242242 # TODO: Support progress callbacks
243243
244- await self ._write_stream .send (SessionMessage (message = JSONRPCMessage (jsonrpc_request )))
244+ await self ._write_stream .send (
245+ SessionMessage (message = JSONRPCMessage (jsonrpc_request ))
246+ )
245247
246248 # request read timeout takes precedence over session read timeout
247249 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