Package org.a2aproject.sdk.server.events

Class EventConsumer

java.lang.Object

org.a2aproject.sdk.server.events.EventConsumer

public class EventConsumer
extends Object

Constructor Summary

Constructors

Constructor	Description
EventConsumer(EventQueue queue, Executor executor)

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	close()
Flow.Publisher<EventQueueItem>	consumeAll()
org.a2aproject.sdk.spec.Event	consumeOne()
EnhancedRunnable.DoneCallback	createAgentRunnableDoneCallback()

Methods inherited from class java.lang.Object

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

Constructor Details

EventConsumer

public EventConsumer(EventQueue queue,
 Executor executor)

Method Details

consumeOne

public org.a2aproject.sdk.spec.Event consumeOne()
                                         throws org.a2aproject.sdk.spec.A2AServerException,
EventQueueClosedException

Throws:

org.a2aproject.sdk.spec.A2AServerException

EventQueueClosedException

consumeAll

public Flow.Publisher<EventQueueItem> consumeAll()

createAgentRunnableDoneCallback

public EnhancedRunnable.DoneCallback createAgentRunnableDoneCallback()

cancel

public void cancel()

close

public void close()