Method stop_streaming

src/mcp_cli/display/manager.py:155–194

Stop streaming and return final content. Args: interrupted: Whether streaming was interrupted by user Returns: Final accumulated content

(self, interrupted: bool = False)

        await self._trigger_refresh()

    async def stop_streaming(self, interrupted: bool = False) -> str:
        """Stop streaming and return final content.

        Args:
            interrupted: Whether streaming was interrupted by user

        Returns:
            Final accumulated content
        """
        if not self.streaming_state:
            logger.warning("No active streaming state to stop")
            return ""

        # Mark state as complete
        self.streaming_state.complete(interrupted=interrupted)

        # Stop refresh loop
        await self._stop_refresh_loop()

        # Finish the live display (clear and reset state)
        self._finish_display()

        # Show final output
        final_content = self.streaming_state.accumulated_content
        elapsed = self.streaming_state.elapsed_time
        chunks_received = self.streaming_state.chunks_received

        if final_content:
            self._show_final_response(final_content, elapsed, interrupted)

        logger.debug(
            f"Stopped streaming: {len(final_content)} chars in {elapsed:.2f}s, "
            f"{chunks_received} chunks"
        )

        # Clear streaming state to avoid any interference with subsequent tool execution
        # This ensures the display manager is in a clean state for the next operation
        self.streaming_state = None

        return final_content

    # ==================== TOOL EXECUTION OPERATIONS ====================