o ưi@s<dZddlmZmZddlmZmZmZGdddeZdS)z0 Base configuration for A2A protocol providers. )ABCabstractmethod)Any AsyncIteratorDictc @speZdZdZededeeefdedeeeffddZededeeefdede eeeffdd Z d S) 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. request_idparamsapi_basereturncsdS)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 Nselfrr r kwargsr r Z/home/app/Keep/.python/lib/python3.10/site-packages/litellm/a2a_protocol/providers/base.pyhandle_non_streamingsz*BaseA2AProviderConfig.handle_non_streamingcKsdS)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 FNr r r r rhandle_streaming'sz&BaseA2AProviderConfig.handle_streamingN) __name__ __module__ __qualname____doc__rstrrrrrrr r r rr s,    rN) rabcrrtypingrrrrr r r rs