Uses of Class
com.mulesoft.connectors.a2a.api.model.transport.StreamingResponseAttributes

Packages that use StreamingResponseAttributes

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

Uses of StreamingResponseAttributes in com.mulesoft.connectors.a2a.internal.client.helper

Methods in com.mulesoft.connectors.a2a.internal.client.helper that return StreamingResponseAttributes

Modifier and Type	Method	Description
static StreamingResponseAttributes	ResponseAttributesHelper.createStreamingFromResponseAttributes(ResponseAttributes originalAttributes, Boolean finalEventFound)	Creates StreamingResponseAttributes from existing ResponseAttributes with final event information.

Uses of StreamingResponseAttributes in com.mulesoft.connectors.a2a.internal.client.operation

Method parameters in com.mulesoft.connectors.a2a.internal.client.operation with type arguments of type StreamingResponseAttributes

Modifier and Type	Method	Description
void	ClientOperations.sendStreamMessage(A2AClient client, InputStream streamMessage, RequestParameterGroup requestParameters, org.mule.sdk.api.runtime.source.DistributedTraceContextManager traceContextManager, TaskStatusUpdateRoute onTaskStatusUpdate, TaskArtifactUpdateRoute onTaskArtifactUpdate, org.mule.runtime.extension.api.runtime.process.CompletionCallback<String,StreamingResponseAttributes> completionCallback)	Sends a message to the A2A agent and establishes an SSE streaming connection to receive real-time status updates, artifacts, and error notifications as the agent processes the request.
void	ClientOperations.taskResubscribe(A2AClient client, InputStream taskIdParams, RequestParameterGroup requestParameters, org.mule.sdk.api.runtime.source.DistributedTraceContextManager traceContextManager, TaskStatusUpdateRoute onTaskStatusUpdate, TaskArtifactUpdateRoute onTaskArtifactUpdate, org.mule.runtime.extension.api.runtime.process.CompletionCallback<String,StreamingResponseAttributes> completionCallback)	Reconnects to an existing SSE streaming session for an ongoing task to receive buffered events and continue receiving real-time updates from where the connection was lost.