Uses of Class
org.a2aproject.sdk.grpc.StreamResponse

Packages that use StreamResponse

Package	Description
org.a2aproject.sdk.client.transport.grpc
org.a2aproject.sdk.grpc
org.a2aproject.sdk.grpc.mapper
org.a2aproject.sdk.grpc.utils
org.a2aproject.sdk.transport.grpc.handler	gRPC transport handler implementations for the A2A protocol.

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

Methods in org.a2aproject.sdk.client.transport.grpc with parameters of type StreamResponse

Modifier and Type	Method	Description
void	EventStreamObserver.onNext(StreamResponse response)

Uses of StreamResponse in org.a2aproject.sdk.grpc

Methods in org.a2aproject.sdk.grpc that return StreamResponse

Modifier and Type	Method	Description
StreamResponse	StreamResponse.Builder.build()
StreamResponse	StreamResponse.Builder.buildPartial()
static StreamResponse	StreamResponse.getDefaultInstance()
StreamResponse	StreamResponse.Builder.getDefaultInstanceForType()
StreamResponse	StreamResponse.getDefaultInstanceForType()
static StreamResponse	StreamResponse.parseDelimitedFrom(InputStream input)
static StreamResponse	StreamResponse.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamResponse	StreamResponse.parseFrom(byte[] data)
static StreamResponse	StreamResponse.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamResponse	StreamResponse.parseFrom(com.google.protobuf.ByteString data)
static StreamResponse	StreamResponse.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamResponse	StreamResponse.parseFrom(com.google.protobuf.CodedInputStream input)
static StreamResponse	StreamResponse.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamResponse	StreamResponse.parseFrom(InputStream input)
static StreamResponse	StreamResponse.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StreamResponse	StreamResponse.parseFrom(ByteBuffer data)
static StreamResponse	StreamResponse.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in org.a2aproject.sdk.grpc that return types with arguments of type StreamResponse

Modifier and Type	Method	Description
com.google.protobuf.Parser<StreamResponse>	StreamResponse.getParserForType()
static io.grpc.MethodDescriptor<SendMessageRequest,StreamResponse>	A2AServiceGrpc.getSendStreamingMessageMethod()
static io.grpc.MethodDescriptor<SubscribeToTaskRequest,StreamResponse>	A2AServiceGrpc.getSubscribeToTaskMethod()
static com.google.protobuf.Parser<StreamResponse>	StreamResponse.parser()
Iterator<StreamResponse>	A2AServiceGrpc.A2AServiceBlockingStub.sendStreamingMessage(SendMessageRequest request)	Sends a streaming message to an agent, allowing for real-time interaction and status updates.
io.grpc.stub.BlockingClientCall<?,StreamResponse>	A2AServiceGrpc.A2AServiceBlockingV2Stub.sendStreamingMessage(SendMessageRequest request)	Sends a streaming message to an agent, allowing for real-time interaction and status updates.
Iterator<StreamResponse>	A2AServiceGrpc.A2AServiceBlockingStub.subscribeToTask(SubscribeToTaskRequest request)	Subscribes to task updates for tasks not in a terminal state.
io.grpc.stub.BlockingClientCall<?,StreamResponse>	A2AServiceGrpc.A2AServiceBlockingV2Stub.subscribeToTask(SubscribeToTaskRequest request)	Subscribes to task updates for tasks not in a terminal state.

Methods in org.a2aproject.sdk.grpc with parameters of type StreamResponse

Modifier and Type	Method	Description
StreamResponse.Builder	StreamResponse.Builder.mergeFrom(StreamResponse other)
static StreamResponse.Builder	StreamResponse.newBuilder(StreamResponse prototype)

Method parameters in org.a2aproject.sdk.grpc with type arguments of type StreamResponse

Modifier and Type	Method	Description
void	A2AServiceGrpc.A2AServiceStub.sendStreamingMessage(SendMessageRequest request, io.grpc.stub.StreamObserver<StreamResponse> responseObserver)	Sends a streaming message to an agent, allowing for real-time interaction and status updates.
default void	A2AServiceGrpc.AsyncService.sendStreamingMessage(SendMessageRequest request, io.grpc.stub.StreamObserver<StreamResponse> responseObserver)	Sends a streaming message to an agent, allowing for real-time interaction and status updates.
void	A2AServiceGrpc.A2AServiceStub.subscribeToTask(SubscribeToTaskRequest request, io.grpc.stub.StreamObserver<StreamResponse> responseObserver)	Subscribes to task updates for tasks not in a terminal state.
default void	A2AServiceGrpc.AsyncService.subscribeToTask(SubscribeToTaskRequest request, io.grpc.stub.StreamObserver<StreamResponse> responseObserver)	Subscribes to task updates for tasks not in a terminal state.

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

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

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

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

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

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

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

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

Uses of StreamResponse in org.a2aproject.sdk.transport.grpc.handler

Method parameters in org.a2aproject.sdk.transport.grpc.handler with type arguments of type StreamResponse

Modifier and Type	Method	Description
void	GrpcHandler.sendStreamingMessage(SendMessageRequest request, io.grpc.stub.StreamObserver<StreamResponse> responseObserver)	Handles a server streaming message send request.
void	GrpcHandler.subscribeToTask(SubscribeToTaskRequest request, io.grpc.stub.StreamObserver<StreamResponse> responseObserver)