Method drain_boot_output

ci/rpc_client.py:291–332

Drain pending boot output from serial buffer (async). Args: max_lines: Maximum lines to drain verbose: Print drained lines Returns: Number of lines drained

(
        self, max_lines: int = 100, verbose: bool = False
    )

            await asyncio.sleep(0)  # Yield control

    async def drain_boot_output(
        self, max_lines: int = 100, verbose: bool = False
    ) -> int:
        """Drain pending boot output from serial buffer (async).

        Args:
            max_lines: Maximum lines to drain
            verbose: Print drained lines

        Returns:
            Number of lines drained
        """
        if not self.is_connected:
            raise RpcError("Not connected")

        assert self._serial is not None

        lines_drained = 0

        # Poll for boot output with short timeout (wait for buffer to drain)
        # Use read_lines with a short timeout to drain existing buffer
        try:
            async for line in self._serial.read_lines(timeout=1.0):
                self._check_interrupt()
                lines_drained += 1

                if verbose:
                    if lines_drained <= 3:
                        print(f"  [boot] {line[:80]}")
                    elif lines_drained == 4:
                        print("  [boot] ... (draining boot output)")

                if lines_drained >= max_lines:
                    break

        except KeyboardInterrupt:
            notify_main_thread()
            raise
        except Exception:
            pass  # Timeout is normal when buffer is drained

        return lines_drained

    async def send(
        self,