Fix stream type errors

Author: dandavison

mcp_examples/common/mcp_sdk_nexus_transport.py

@@ -4,6 +4,7 @@
 
 import anyio
 import mcp.types as types
+from anyio.streams.memory import MemoryObjectReceiveStream, MemoryObjectSendStream
 from mcp.shared.message import SessionMessage
 
 from mcp_examples.common.mcp_server_nexus_service import (
@@ -128,7 +129,9 @@ async def _route_to_nexus(
         return SessionMessage(types.JSONRPCMessage(root=response))
 
 
-class AsyncioQueueStream:
+class AsyncioQueueStream(
+    MemoryObjectSendStream[SessionMessage], MemoryObjectReceiveStream[SessionMessage]
+):
     def __init__(self, queue: asyncio.Queue):
         self.queue = queue
         self._closed = False

mcp_examples/nexus_transport/app.py

@@ -43,10 +43,12 @@ async def create_client_session_and_call_tool_using_nexus_transport(
 @workflow.defn
 class CallToolWorkflow:
     def __init__(self):
+        print("Creating nexus client in workflow...")
         self.nexus_client = workflow.create_nexus_client(
             service=MCPServerNexusService,
             endpoint="mcp-sequential-thinking-nexus-endpoint",
         )
+        print("Nexus client created")
 
     @workflow.run
     async def run(self):
@@ -93,6 +95,7 @@ async def _call_tool(session: ClientSession):
 
 
 if __name__ == "__main__":
+    print("Starting app...")
     if "WITHOUT_WORKFLOW" in os.environ:
         asyncio.run(create_client_session_and_call_tool_using_standard_transport())
     else: