Uses of Interface
org.a2aproject.sdk.spec.StreamingEventKind

Packages that use StreamingEventKind

Package	Description
org.a2aproject.sdk.client.transport.grpc
org.a2aproject.sdk.client.transport.jsonrpc
org.a2aproject.sdk.client.transport.jsonrpc.sse
org.a2aproject.sdk.client.transport.rest
org.a2aproject.sdk.client.transport.rest.sse
org.a2aproject.sdk.client.transport.spi
org.a2aproject.sdk.client.transport.spi.sse
org.a2aproject.sdk.compat03.conversion
org.a2aproject.sdk.compat03.conversion.mappers.domain
org.a2aproject.sdk.extras.opentelemetry	Common OpenTelemetry utilities and shared components for A2A Java SDK.
org.a2aproject.sdk.extras.opentelemetry.client
org.a2aproject.sdk.extras.opentelemetry.client.propagation
org.a2aproject.sdk.extras.queuemanager.replicated.core
org.a2aproject.sdk.grpc.mapper
org.a2aproject.sdk.grpc.utils
org.a2aproject.sdk.jsonrpc.common.wrappers	JSON-RPC 2.0 protocol message wrappers for the A2A Protocol.
org.a2aproject.sdk.server.requesthandlers
org.a2aproject.sdk.server.tasks
org.a2aproject.sdk.spec	JSON processing exceptions for the A2A Java SDK.

Uses of StreamingEventKind in org.a2aproject.sdk.client.transport.grpc

Method parameters in org.a2aproject.sdk.client.transport.grpc with type arguments of type StreamingEventKind

Modifier and Type	Method	Description
void	GrpcTransport.sendMessageStreaming(MessageSendParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)
void	GrpcTransport.subscribeToTask(TaskIdParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)

Constructor parameters in org.a2aproject.sdk.client.transport.grpc with type arguments of type StreamingEventKind

Modifier	Constructor	Description
	EventStreamObserver(Consumer<StreamingEventKind> eventHandler, Consumer<Throwable> errorHandler)

Uses of StreamingEventKind in org.a2aproject.sdk.client.transport.jsonrpc

Method parameters in org.a2aproject.sdk.client.transport.jsonrpc with type arguments of type StreamingEventKind

Modifier and Type	Method	Description
void	JSONRPCTransport.sendMessageStreaming(MessageSendParams request, Consumer<StreamingEventKind> eventConsumer, @Nullable Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)
void	JSONRPCTransport.subscribeToTask(TaskIdParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)

Uses of StreamingEventKind in org.a2aproject.sdk.client.transport.jsonrpc.sse

Constructor parameters in org.a2aproject.sdk.client.transport.jsonrpc.sse with type arguments of type StreamingEventKind

Modifier	Constructor	Description
	SSEEventListener(Consumer<StreamingEventKind> eventHandler, @Nullable Consumer<Throwable> errorHandler)

Uses of StreamingEventKind in org.a2aproject.sdk.client.transport.rest

Method parameters in org.a2aproject.sdk.client.transport.rest with type arguments of type StreamingEventKind

Modifier and Type	Method	Description
void	RestTransport.sendMessageStreaming(MessageSendParams messageSendParams, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)
void	RestTransport.subscribeToTask(TaskIdParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)

Uses of StreamingEventKind in org.a2aproject.sdk.client.transport.rest.sse

Constructor parameters in org.a2aproject.sdk.client.transport.rest.sse with type arguments of type StreamingEventKind

Modifier	Constructor	Description
	SSEEventListener(Consumer<StreamingEventKind> eventHandler, @Nullable Consumer<Throwable> errorHandler)

Uses of StreamingEventKind in org.a2aproject.sdk.client.transport.spi

Method parameters in org.a2aproject.sdk.client.transport.spi with type arguments of type StreamingEventKind

Modifier and Type	Method	Description
void	ClientTransport.sendMessageStreaming(MessageSendParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)	Send a streaming message request to the agent and receive responses as they arrive.
void	ClientTransport.subscribeToTask(TaskIdParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)	Reconnect to get task updates for an existing task.

Uses of StreamingEventKind in org.a2aproject.sdk.client.transport.spi.sse

Methods in org.a2aproject.sdk.client.transport.spi.sse that return types with arguments of type StreamingEventKind

Modifier and Type	Method	Description
protected Consumer<StreamingEventKind>	AbstractSSEEventListener.getEventHandler()	Gets the event handler for processing streaming events.

Methods in org.a2aproject.sdk.client.transport.spi.sse with parameters of type StreamingEventKind

Modifier and Type	Method	Description
protected void	AbstractSSEEventListener.handleEvent(StreamingEventKind event, @Nullable Future<Void> future)	Processes a parsed streaming event and handles auto-close logic for final events.
protected boolean	AbstractSSEEventListener.shouldAutoClose(StreamingEventKind event)	Determines if the SSE connection should be automatically closed based on the event type.

Constructor parameters in org.a2aproject.sdk.client.transport.spi.sse with type arguments of type StreamingEventKind

Modifier	Constructor	Description
protected	AbstractSSEEventListener(Consumer<StreamingEventKind> eventHandler, @Nullable Consumer<Throwable> errorHandler)	Creates a new SSE event listener with the specified handlers.

Uses of StreamingEventKind in org.a2aproject.sdk.compat03.conversion

Methods in org.a2aproject.sdk.compat03.conversion with parameters of type StreamingEventKind

Modifier and Type	Method	Description
@Nullable String	PushNotificationPayloadFormatter_v0_3.formatPayload(StreamingEventKind event, @Nullable Task taskSnapshot)

Uses of StreamingEventKind in org.a2aproject.sdk.compat03.conversion.mappers.domain

Methods in org.a2aproject.sdk.compat03.conversion.mappers.domain that return StreamingEventKind

Modifier and Type	Method	Description
default StreamingEventKind	StreamingEventKindMapper_v0_3.toV10(StreamingEventKind_v0_3 v03)	Converts v0.3 StreamingEventKind to v1.0 StreamingEventKind.

Methods in org.a2aproject.sdk.compat03.conversion.mappers.domain with parameters of type StreamingEventKind

Modifier and Type	Method	Description
default StreamingEventKind_v0_3	StreamingEventKindMapper_v0_3.fromV10(StreamingEventKind v10)	Converts v1.0 StreamingEventKind to v0.3 StreamingEventKind.

Uses of StreamingEventKind in org.a2aproject.sdk.extras.opentelemetry

Methods in org.a2aproject.sdk.extras.opentelemetry that return types with arguments of type StreamingEventKind

Modifier and Type	Method	Description
Flow.Publisher<StreamingEventKind>	OpenTelemetryRequestHandlerDecorator.onMessageSendStream(MessageSendParams params, ServerCallContext context)
Flow.Publisher<StreamingEventKind>	OpenTelemetryRequestHandlerDecorator.onSubscribeToTask(TaskIdParams params, ServerCallContext context)

Uses of StreamingEventKind in org.a2aproject.sdk.extras.opentelemetry.client

Method parameters in org.a2aproject.sdk.extras.opentelemetry.client with type arguments of type StreamingEventKind

Modifier and Type	Method	Description
void	OpenTelemetryClientTransport.sendMessageStreaming(MessageSendParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)
void	OpenTelemetryClientTransport.subscribeToTask(TaskIdParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)

Uses of StreamingEventKind in org.a2aproject.sdk.extras.opentelemetry.client.propagation

Method parameters in org.a2aproject.sdk.extras.opentelemetry.client.propagation with type arguments of type StreamingEventKind

Modifier and Type	Method	Description
void	OpenTelemetryClientPropagatorTransport.sendMessageStreaming(MessageSendParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)
void	OpenTelemetryClientPropagatorTransport.subscribeToTask(TaskIdParams request, Consumer<StreamingEventKind> eventConsumer, Consumer<Throwable> errorConsumer, @Nullable ClientCallContext context)

Uses of StreamingEventKind in org.a2aproject.sdk.extras.queuemanager.replicated.core

Methods in org.a2aproject.sdk.extras.queuemanager.replicated.core that return StreamingEventKind

Modifier and Type	Method	Description
StreamingEventKind	ReplicatedEventQueueItem.getStreamingEvent()	Get the StreamingEventKind event field (for JSON serialization).

Methods in org.a2aproject.sdk.extras.queuemanager.replicated.core with parameters of type StreamingEventKind

Modifier and Type	Method	Description
void	ReplicatedEventQueueItem.setEvent(StreamingEventKind event)

Constructors in org.a2aproject.sdk.extras.queuemanager.replicated.core with parameters of type StreamingEventKind

Modifier	Constructor	Description
	ReplicatedEventQueueItem(String taskId, StreamingEventKind event)

Uses of StreamingEventKind in org.a2aproject.sdk.grpc.mapper

Methods in org.a2aproject.sdk.grpc.mapper that return StreamingEventKind

Modifier and Type	Method	Description
default StreamingEventKind	StreamResponseMapper.fromProto(StreamResponse proto)	Converts proto StreamResponse to domain StreamingEventKind.

Methods in org.a2aproject.sdk.grpc.mapper with parameters of type StreamingEventKind

Modifier and Type	Method	Description
default StreamResponse	StreamResponseMapper.toProto(StreamingEventKind domain)	Converts domain StreamingEventKind to proto StreamResponse.

Uses of StreamingEventKind in org.a2aproject.sdk.grpc.utils

Methods in org.a2aproject.sdk.grpc.utils that return StreamingEventKind

Modifier and Type	Method	Description
static StreamingEventKind	ProtoUtils.FromProto.streamingEventKind(StreamResponseOrBuilder streamResponse)

Methods in org.a2aproject.sdk.grpc.utils with parameters of type StreamingEventKind

Modifier and Type	Method	Description
static StreamResponse	ProtoUtils.ToProto.streamResponse(StreamingEventKind streamingEventKind)
static StreamResponse	ProtoUtils.ToProto.taskOrMessageStream(StreamingEventKind eventKind)

Uses of StreamingEventKind in org.a2aproject.sdk.jsonrpc.common.wrappers

Constructors in org.a2aproject.sdk.jsonrpc.common.wrappers with parameters of type StreamingEventKind

Modifier	Constructor	Description
	SendStreamingMessageResponse(Object id, StreamingEventKind result)	Constructs successful response.
	SendStreamingMessageResponse(String jsonrpc, Object id, StreamingEventKind result, A2AError error)	Constructs response with all parameters.

Uses of StreamingEventKind in org.a2aproject.sdk.server.requesthandlers

Methods in org.a2aproject.sdk.server.requesthandlers that return types with arguments of type StreamingEventKind

Modifier and Type	Method	Description
Flow.Publisher<StreamingEventKind>	AuthorizationRequestHandlerDecorator.onMessageSendStream(MessageSendParams params, ServerCallContext context)
Flow.Publisher<StreamingEventKind>	DefaultRequestHandler.onMessageSendStream(MessageSendParams params, ServerCallContext context)
Flow.Publisher<StreamingEventKind>	RequestHandler.onMessageSendStream(MessageSendParams params, ServerCallContext context)
Flow.Publisher<StreamingEventKind>	AuthorizationRequestHandlerDecorator.onSubscribeToTask(TaskIdParams params, ServerCallContext context)
Flow.Publisher<StreamingEventKind>	DefaultRequestHandler.onSubscribeToTask(TaskIdParams params, ServerCallContext context)
Flow.Publisher<StreamingEventKind>	RequestHandler.onSubscribeToTask(TaskIdParams params, ServerCallContext context)

Uses of StreamingEventKind in org.a2aproject.sdk.server.tasks

Methods in org.a2aproject.sdk.server.tasks with parameters of type StreamingEventKind

Modifier and Type	Method	Description
protected @Nullable String	BasePushNotificationSender.extractTaskId(StreamingEventKind event)	Extracts the task ID from a StreamingEventKind event.
@Nullable String	PushNotificationPayloadFormatter.formatPayload(StreamingEventKind event, @Nullable Task taskSnapshot)
void	BasePushNotificationSender.sendNotification(StreamingEventKind event, @Nullable Task taskSnapshot)
void	PushNotificationSender.sendNotification(StreamingEventKind event, @Nullable Task taskSnapshot)	Sends a push notification containing a streaming event.

Uses of StreamingEventKind in org.a2aproject.sdk.spec

Classes in org.a2aproject.sdk.spec that implement StreamingEventKind

Modifier and Type	Class	Description
final record	Message	Represents a single message in the conversation between a user and an agent in the A2A Protocol.
final record	Task	Represents a single, stateful operation or conversation between a client and an agent in the A2A Protocol.
final record	TaskArtifactUpdateEvent	Event notifying that a task artifact has been created, modified, or appended to.
final record	TaskStatusUpdateEvent	An event sent by the agent to notify the client of a change in a task's status.