async def _handle_sse_event(
    self,
    sse: ServerSentEvent,
    read_stream_writer: StreamWriter,
    original_request_id: RequestId | None = None,
    resumption_callback: Callable[[str], Awaitable[None]] | None = None,
    is_initialization: bool = False,
) -> bool:
    """Handle an SSE event, returning True if the response is complete."""
    if sse.event == "message":
        try:
            message = JSONRPCMessage.model_validate_json(sse.data) ##### threw the exception
            logger.debug(f"SSE message: {message}")

            # Extract protocol version from initialization response
            if is_initialization:
                self._maybe_extract_protocol_version_from_message(message)

            # If this is a response and we have original_request_id, replace it
            if original_request_id is not None and isinstance(message.root, JSONRPCResponse | JSONRPCError):
                message.root.id = original_request_id

            session_message = SessionMessage(message)
            await read_stream_writer.send(session_message)

            # Call resumption token callback if we have an ID
            if sse.id and resumption_callback:
                await resumption_callback(sse.id)

            # If this is a response or error return True indicating completion
            # Otherwise, return False to continue listening
            return isinstance(message.root, JSONRPCResponse | JSONRPCError)

        except Exception as exc:
            ##### handled exception but client did not receive ######
            logger.exception("Error parsing SSE message")
            await read_stream_writer.send(exc)
            return False
    else:
        logger.warning(f"Unknown SSE event: {sse.event}")
        return False