Client streamable http

src/conduit/client/session.py

@@ -172,6 +172,8 @@ async def disconnect_all_servers(self) -> None:
         for server_id in self.server_manager.get_server_ids():
             await self.disconnect_server(server_id)
 
+        await self.transport.close()
+
     # ================================
     # Initialization
     # ================================

src/conduit/server/session.py

@@ -172,6 +172,8 @@ async def disconnect_all_clients(self) -> None:
         for client_id in self.client_manager.get_client_ids():
             await self.disconnect_client(client_id)
 
+        await self.transport.close()
+
     # ================================
     # Initialization
     # ================================

src/conduit/transport/client.py

@@ -68,3 +68,12 @@ async def disconnect_server(self, server_id: str) -> None:
             server_id: Server connection ID to disconnect
         """
         ...
+
+    @abstractmethod
+    async def close(self) -> None:
+        """Close the transport and clean up all resources.
+
+        Should be called when the transport is no longer needed.
+        Safe to call multiple times - subsequent calls are no-ops.
+        """
+        ...

src/conduit/transport/server.py

@@ -66,3 +66,12 @@ async def disconnect_client(self, client_id: str) -> None:
             client_id: Client connection ID to disconnect
         """
         ...
+
+    @abstractmethod
+    async def close(self) -> None:
+        """Close the transport and clean up all resources.
+
+        Should be called when the transport is no longer needed.
+        Safe to call multiple times - subsequent calls are no-ops.
+        """
+        ...

src/conduit/transport/stdio/client.py

@@ -345,3 +345,8 @@ async def _shutdown_server_process(
             logger.error(f"Error during shutdown of server '{server_id}': {e}")
         finally:
             server_process.process = None
+
+    async def close(self) -> None:
+        """Close the transport and clean up all resources."""
+        for server_id in list(self._servers):
+            await self.disconnect_server(server_id)

src/conduit/transport/stdio/server.py

@@ -101,3 +101,12 @@ async def disconnect_client(self, client_id: str) -> None:
             pass
 
         sys.exit(0)
+
+    async def close(self) -> None:
+        """Close the transport and clean up all resources."""
+        try:
+            sys.stdout.close()
+        except Exception:
+            pass
+
+        sys.exit(0)