Xjo(dZddlmZddlmZddlmZddlmZddl m Z ddl Z ddl m Z mZddlmZdd lmZmZmZmZmZmZdd lmZdd lmZdd lmZee eezeefZ edd Z!e d ddZ"y)z In-memory transports ) annotations)AsyncGenerator)asynccontextmanager) timedelta)AnyN)MemoryObjectReceiveStreamMemoryObjectSendStream) ClientSessionElicitationFnT ListRootsFnT LoggingFnTMessageHandlerFnT SamplingFnT)Server)FastMCP)SessionMessagec bKtjttzd\}}tjttzd\}}||f}||f}|4d{|4d{|4d{|4d{||fdddd{dddd{dddd{dddd{y7m7d7[7R7=#1d{7swYMxYw7D#1d{7swYTxYw7K#1d{7swY[xYw7R#1d{7swYyxYww)z Creates a pair of bidirectional memory streams for client-server communication. Returns: A tuple of (client_streams, server_streams) where each is a tuple of (read_stream, write_stream) N)anyiocreate_memory_object_streamr Exception)server_to_client_sendserver_to_client_receiveclient_to_server_sendclient_to_server_receiveclient_streamsserver_streamss e/mnt/ssd/data/Dropbox/adrian/vault-secondbrain/venv/lib/python3.12/site-packages/mcp/shared/memory.py#create_client_server_memory_streamsrsD7<6W6WXfirXr6stu6v336;6W6WXfirXr6stu6v33.0EFN.0EFN !---- !--  -- n,, ----------------------------s AD/C D/!D(C )D,D3C 4D7C,>C ?C,C C,C C, D%C*&D* D5D6D: D/DD/ DDC,C,C' CC' #C,*D,C> 2C53C> :DDD D  D DD/D, D# !D,(D/c Kttr jt4d{\} } | \} } | \t j 4d{} | j fd t| | ||||||| 4d{}|jd{|dddd{| jjdddd{dddd{y777p7Z7G#1d{7swYWxYw#| jjwxYw7S#1d{7swYcxYw7Z#1d{7swYyxYww)zBCreates a ClientSession that is connected to a running MCP server.NcJjjS)N)raise_exceptions)runcreate_initialization_options)r"server server_read server_writesrz.Ks*  88:%5 #) read_stream write_streamread_timeout_secondssampling_callbacklist_roots_callbacklogging_callbackmessage_handler client_infoelicitation_callback) isinstancer _mcp_serverrrcreate_task_group start_soonr initialize cancel_scopecancel)r%r,r-r.r/r0r1r"r2rr client_read client_writetgclient_sessionr&r's` ` @@r*create_connected_server_and_client_sessionr>1s_ &'"##24))8X$2! \$2! \**, ) ) MM  )( +!-)=&7(;%5$3 +)=  ) )$(33555(( ) )&&(3 ) ) )))  ) )6 ) ) ) )&&(3 ) ) ) ) ))))s+E)C=E)&EC?ED=8DD DD(D ) D2 D=D>DD= E'D;(E, E)7E8E)?EDDDD DD DD88D=;E=E EE EE)E&E E&"E))returnz9AsyncGenerator[tuple[MessageStream, MessageStream], None])NNNNNNFN)r%zServer[Any] | FastMCPr,ztimedelta | Noner-zSamplingFnT | Noner.zListRootsFnT | Noner/zLoggingFnT | Noner0zMessageHandlerFnT | Noner1ztypes.Implementation | Noner"boolr2zElicitationFnT | Noner?z#AsyncGenerator[ClientSession, None])#__doc__ __future__rcollections.abcr contextlibrdatetimertypingrranyio.streams.memoryrr mcp.typestypesmcp.client.sessionr r r r rr mcp.serverrmcp.server.fastmcprmcp.shared.messagertupler MessageStreamrr>r)rrQs#** Rvv&-/0JKMcdrMsst --0.2,0/3*.04/3"260) !0)*0)*0)- 0) ( 0) . 0)-0)0)00))0)0)r)