a2a.server.tasks.result_aggregator.ResultAggregator
There are three main ways to use the ResultAggregator:
2) As part of a blocking call.
consumer: EventConsumer
blocking: bool = True
If blocking is True, it waits for completion unless an auth_required state is encountered, which is always an interruption.
返り値 tuple[Task | Message | None, bool]
A boolean indicating whether the consumption was interrupted (True) or completed naturally (False).
async for event in consumer.consume_all()して
eventがMessageならそれを返して終わり（return event, False）
eventがTaskの場合（積ん読）