Method start_streaming

src/mcp_cli/display/manager.py:110–120

Start a new streaming operation.

(self)

    # ==================== STREAMING OPERATIONS ====================

    async def start_streaming(self) -> None:
        """Start a new streaming operation."""
        if self.streaming_state and self.streaming_state.is_active:
            logger.warning("Streaming already active, stopping previous stream")
            await self.stop_streaming(interrupted=True)

        self.streaming_state = StreamingState()
        self._refresh_active = True
        await self._start_refresh_loop()

        logger.debug("Started streaming display")

    async def add_chunk(self, raw_chunk: dict) -> None:
        """Process and display a new chunk.