a2a.server.request_handlers.DefaultRequestHandler

This handler provides default implementations for all A2A JSON-RPC methods,

Default handler for 'message/send' interface (non-streaming).

consumer = EventConsumer(queue)

返り値 result: MessageかTaskを返す

result, interrupted_or_non_blocking = await result_aggregator.consume_and_break_on_interrupt(consumer, blocking)