Package com.mulesoft.connectors.a2a.internal.client.operation

Class SseManager

java.lang.Object

com.mulesoft.connectors.a2a.internal.client.operation.SseManager

public class SseManager
extends Object

Constructor Summary

Constructors

Constructor	Description
SseManager(A2ASerializer a2ASerializer)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<SseSessionResult>	startSseSession(SseConnectionResult sseConnectionResult, TaskStatusUpdateRoute onTaskStatusUpdate, TaskArtifactUpdateRoute onTaskArtifactUpdate)	Starts an SSE session, handling events and executing routes until the session completes.

Methods inherited from class java.lang.Object

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

Constructor Details

SseManager

public SseManager(A2ASerializer a2ASerializer)

Method Details

startSseSession

public CompletableFuture<SseSessionResult> startSseSession(SseConnectionResult sseConnectionResult,
 TaskStatusUpdateRoute onTaskStatusUpdate,
 TaskArtifactUpdateRoute onTaskArtifactUpdate)

Starts an SSE session, handling events and executing routes until the session completes.

Parameters:

sseConnectionResult - The SSE connection result containing source and response attributes

onTaskStatusUpdate - Route for status updates

onTaskArtifactUpdate - Route for artifact updates

Returns:

CompletableFuture that completes with collected events when session ends