Method _read_exact

python/copilot/_jsonrpc.py:306–327

Read exactly num_bytes, handling partial/short reads from pipes. Args: num_bytes: Number of bytes to read Returns: Bytes read from stream Raises: EOFError: If stream ends before reading all bytes

(self, num_bytes: int)

                    loop.call_soon_threadsafe(future.set_exception, exc)

    def _read_exact(self, num_bytes: int) -> bytes:
        """
        Read exactly num_bytes, handling partial/short reads from pipes.

        Args:
            num_bytes: Number of bytes to read

        Returns:
            Bytes read from stream

        Raises:
            EOFError: If stream ends before reading all bytes
        """
        chunks = []
        remaining = num_bytes
        while remaining > 0:
            chunk = self.process.stdout.read(remaining)
            if not chunk:
                raise EOFError("Unexpected end of stream while reading JSON-RPC message")
            chunks.append(chunk)
            remaining -= len(chunk)
        return b"".join(chunks)

    def _read_message(self) -> dict | None:
        """