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, @Nullable Message message, Executor executor, Executor eventConsumerExecutor)

Method Summary

Modifier and Type	Method	Description
EventKind	consumeAll(EventConsumer consumer)
ResultAggregator.EventTypeAndInterrupt	consumeAndBreakOnInterrupt(EventConsumer consumer, boolean blocking)
Flow.Publisher<EventQueueItem>	consumeAndEmit(EventConsumer consumer)
@Nullable 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,
 @Nullable Message message,
 Executor executor,
 Executor eventConsumerExecutor)

Method Details

getCurrentResult

public @Nullable EventKind getCurrentResult()

consumeAndEmit

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

consumeAll

public EventKind consumeAll(EventConsumer consumer)
                     throws A2AError

Throws:

A2AError

consumeAndBreakOnInterrupt

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

Throws:

A2AError