Method _initialize_stream_manager

src/mcp_cli/tools/manager.py:218–354

Initialize StreamManager with detected transport type. ENHANCED: Initializes different transport types in parallel for faster startup.

(self, namespace: str)

        logger.debug(f"Progress: {message}")

    async def _initialize_stream_manager(self, namespace: str) -> bool:
        """Initialize StreamManager with detected transport type.

        ENHANCED: Initializes different transport types in parallel for faster startup.
        """
        self.stream_manager = StreamManager()

        http_servers = self._config_loader.http_servers
        sse_servers = self._config_loader.sse_servers
        stdio_servers = self._config_loader.stdio_servers

        if not (http_servers or sse_servers or stdio_servers):
            logger.info("No servers detected")
            return True

        try:
            # Build initialization tasks for parallel execution
            init_tasks: list[asyncio.Task[None]] = []
            task_names: list[str] = []

            # Create OAuth callback once (shared by HTTP and SSE)
            oauth_callback = self._config_loader.create_oauth_refresh_callback(
                http_servers, sse_servers
            )

            if http_servers:
                self._report_progress(
                    f"Connecting to {len(http_servers)} HTTP server(s)..."
                )
                logger.info(f"Preparing {len(http_servers)} HTTP servers for init")
                http_dicts = [
                    {"name": s.name, "url": s.url, "headers": s.headers or {}}
                    for s in http_servers
                ]
                task = asyncio.create_task(
                    self.stream_manager.initialize_with_http_streamable(
                        servers=http_dicts,
                        server_names=self.server_names,
                        initialization_timeout=self.initialization_timeout,
                        oauth_refresh_callback=oauth_callback,
                    ),
                    name="init_http",
                )
                init_tasks.append(task)
                task_names.append("HTTP")

            if sse_servers:
                self._report_progress(
                    f"Connecting to {len(sse_servers)} SSE server(s)..."
                )
                logger.info(f"Preparing {len(sse_servers)} SSE servers for init")
                sse_dicts = [
                    {"name": s.name, "url": s.url, "headers": s.headers or {}}
                    for s in sse_servers
                ]
                task = asyncio.create_task(
                    self.stream_manager.initialize_with_sse(
                        servers=sse_dicts,