Package org.a2aproject.sdk.server.tasks

Class ResultAggregator

java.lang.Object

org.a2aproject.sdk.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 org.a2aproject.sdk.spec.Message message, Executor executor, Executor eventConsumerExecutor, long reconciliationTimeoutNanos)

Method Summary

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

Method Details

getCurrentResult

public @Nullable org.a2aproject.sdk.spec.EventKind getCurrentResult()

consumeAndEmit

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

consumeAndBreakOnInterrupt

public ResultAggregator.EventTypeAndInterrupt consumeAndBreakOnInterrupt(EventConsumer consumer,
 boolean blocking)
                                                                  throws org.a2aproject.sdk.spec.A2AError

Throws:

org.a2aproject.sdk.spec.A2AError