uPjFdZddlmZmZddlmZddlmZGddeZy)z0 Base configuration for A2A protocol providers. )ABCabstractmethod) AsyncIterator)Anyc eZdZdZe d dedeeefdedzdeeeffdZe d dedeeefdedzde eeeffdZ y) BaseA2AProviderConfigz Base configuration class for A2A protocol providers. Each provider should implement this interface to define how to handle A2A requests for their specific agent type. N request_idparamsapi_basereturnc Kyw)aX Handle non-streaming A2A request. Args: request_id: A2A JSON-RPC request ID params: A2A MessageSendParams containing the message api_base: Base URL of the agent **kwargs: Additional provider-specific parameters Returns: A2A SendMessageResponse dict Nselfr r r kwargss h/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/a2a_protocol/providers/base.pyhandle_non_streamingz*BaseA2AProviderConfig.handle_non_streamingsc  Kyw)aT Handle streaming A2A request. Args: request_id: A2A JSON-RPC request ID params: A2A MessageSendParams containing the message api_base: Base URL of the agent **kwargs: Additional provider-specific parameters Yields: A2A streaming response events Nrrs rhandle_streamingz&BaseA2AProviderConfig.handle_streaming's , r)N) __name__ __module__ __qualname____doc__rstrdictrrrrrrrr s $   S#X *  c3h   ( $ S#X*  tCH~ & rrN) rabcrrcollections.abcrtypingrrrrrr!s!$)4C4r