Package io.a2a.server.tasks

Class ResultAggregator

java.lang.Object

io.a2a.server.tasks.ResultAggregator

public class ResultAggregator
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ResultAggregator.EventTypeAndInterrupt

Constructor Summary

Constructors

Constructor	Description
ResultAggregator(TaskManager taskManager, Message message, Executor executor)

Method Summary

Modifier and Type	Method	Description
EventKind	consumeAll(EventConsumer consumer)
ResultAggregator.EventTypeAndInterrupt	consumeAndBreakOnInterrupt(EventConsumer consumer, boolean blocking)
Flow.Publisher<EventQueueItem>	consumeAndEmit(EventConsumer consumer)
EventKind	getCurrentResult()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ResultAggregator

public ResultAggregator(TaskManager taskManager,
 Message message,
 Executor executor)

Method Details

getCurrentResult

public EventKind getCurrentResult()

consumeAndEmit

public Flow.Publisher<EventQueueItem> consumeAndEmit(EventConsumer consumer)

consumeAll

public EventKind consumeAll(EventConsumer consumer)
                     throws JSONRPCError

Throws:

JSONRPCError

consumeAndBreakOnInterrupt

public ResultAggregator.EventTypeAndInterrupt consumeAndBreakOnInterrupt(EventConsumer consumer,
 boolean blocking)
                                                                  throws JSONRPCError

Throws:

JSONRPCError