🌐 Uses of Interface io.grpc.stub.StreamObserver (grpc-all 1.75.0 API) - grpc.github.io

Packages that use StreamObserver
Package	Description
io.grpc.channelz.v1
io.grpc.health.v1
io.grpc.lb.v1
io.grpc.protobuf.services	Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.
io.grpc.reflection.v1
io.grpc.reflection.v1alpha
io.grpc.services	Service definitions and utilities for the pre-defined gRPC services.
io.grpc.stub	API for the Stub layer.
io.grpc.testing	API that is useful for testing gRPC.

Uses of StreamObserver in io.grpc.channelz.v1

Methods in io.grpc.channelz.v1 with parameters of type StreamObserver
Modifier and Type	Method	Description
`default void`	ChannelzGrpc.AsyncService.`getChannel(GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver)`	Returns a single Channel, or else a NOT_FOUND code.
`void`	ChannelzGrpc.ChannelzStub.`getChannel(GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver)`	Returns a single Channel, or else a NOT_FOUND code.
`default void`	ChannelzGrpc.AsyncService.`getServer(GetServerRequest request, StreamObserver<GetServerResponse> responseObserver)`	Returns a single Server, or else a NOT_FOUND code.
`void`	ChannelzGrpc.ChannelzStub.`getServer(GetServerRequest request, StreamObserver<GetServerResponse> responseObserver)`	Returns a single Server, or else a NOT_FOUND code.
`default void`	ChannelzGrpc.AsyncService.`getServers(GetServersRequest request, StreamObserver<GetServersResponse> responseObserver)`	Gets all servers that exist in the process.
`void`	ChannelzGrpc.ChannelzStub.`getServers(GetServersRequest request, StreamObserver<GetServersResponse> responseObserver)`	Gets all servers that exist in the process.
`default void`	ChannelzGrpc.AsyncService.`getServerSockets(GetServerSocketsRequest request, StreamObserver<GetServerSocketsResponse> responseObserver)`	Gets all server sockets that exist in the process.
`void`	ChannelzGrpc.ChannelzStub.`getServerSockets(GetServerSocketsRequest request, StreamObserver<GetServerSocketsResponse> responseObserver)`	Gets all server sockets that exist in the process.
`default void`	ChannelzGrpc.AsyncService.`getSocket(GetSocketRequest request, StreamObserver<GetSocketResponse> responseObserver)`	Returns a single Socket or else a NOT_FOUND code.
`void`	ChannelzGrpc.ChannelzStub.`getSocket(GetSocketRequest request, StreamObserver<GetSocketResponse> responseObserver)`	Returns a single Socket or else a NOT_FOUND code.
`default void`	ChannelzGrpc.AsyncService.`getSubchannel(GetSubchannelRequest request, StreamObserver<GetSubchannelResponse> responseObserver)`	Returns a single Subchannel, or else a NOT_FOUND code.
`void`	ChannelzGrpc.ChannelzStub.`getSubchannel(GetSubchannelRequest request, StreamObserver<GetSubchannelResponse> responseObserver)`	Returns a single Subchannel, or else a NOT_FOUND code.
`default void`	ChannelzGrpc.AsyncService.`getTopChannels(GetTopChannelsRequest request, StreamObserver<GetTopChannelsResponse> responseObserver)`	Gets all root channels (i.e.
`void`	ChannelzGrpc.ChannelzStub.`getTopChannels(GetTopChannelsRequest request, StreamObserver<GetTopChannelsResponse> responseObserver)`	Gets all root channels (i.e.

Uses of StreamObserver in io.grpc.health.v1

Methods in io.grpc.health.v1 with parameters of type StreamObserver
Modifier and Type	Method	Description
`default void`	HealthGrpc.AsyncService.`check(HealthCheckRequest request, StreamObserver<HealthCheckResponse> responseObserver)`	If the requested service is unknown, the call will fail with status NOT_FOUND.
`void`	HealthGrpc.HealthStub.`check(HealthCheckRequest request, StreamObserver<HealthCheckResponse> responseObserver)`	If the requested service is unknown, the call will fail with status NOT_FOUND.
`default void`	HealthGrpc.AsyncService.`watch(HealthCheckRequest request, StreamObserver<HealthCheckResponse> responseObserver)`	Performs a watch for the serving status of the requested service.
`void`	HealthGrpc.HealthStub.`watch(HealthCheckRequest request, StreamObserver<HealthCheckResponse> responseObserver)`	Performs a watch for the serving status of the requested service.

Uses of StreamObserver in io.grpc.lb.v1

Methods in io.grpc.lb.v1 that return StreamObserver
Modifier and Type	Method	Description
`default StreamObserver<LoadBalanceRequest>`	LoadBalancerGrpc.AsyncService.`balanceLoad(StreamObserver<LoadBalanceResponse> responseObserver)`	Bidirectional rpc to get a list of servers.
`StreamObserver<LoadBalanceRequest>`	LoadBalancerGrpc.LoadBalancerStub.`balanceLoad(StreamObserver<LoadBalanceResponse> responseObserver)`	Bidirectional rpc to get a list of servers.

Methods in io.grpc.lb.v1 with parameters of type StreamObserver
Modifier and Type	Method	Description
`default StreamObserver<LoadBalanceRequest>`	LoadBalancerGrpc.AsyncService.`balanceLoad(StreamObserver<LoadBalanceResponse> responseObserver)`	Bidirectional rpc to get a list of servers.
`StreamObserver<LoadBalanceRequest>`	LoadBalancerGrpc.LoadBalancerStub.`balanceLoad(StreamObserver<LoadBalanceResponse> responseObserver)`	Bidirectional rpc to get a list of servers.

Uses of StreamObserver in io.grpc.protobuf.services

Methods in io.grpc.protobuf.services that return StreamObserver
Modifier and Type	Method	Description
`StreamObserver<ServerReflectionRequest>`	ProtoReflectionServiceV1.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`

Methods in io.grpc.protobuf.services with parameters of type StreamObserver
Modifier and Type	Method	Description
`void`	ChannelzService.`getChannel(GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver)`	Returns a top level channel aka `ManagedChannel`.
`void`	ChannelzService.`getServer(GetServerRequest request, StreamObserver<GetServerResponse> responseObserver)`	Returns a server.
`void`	ChannelzService.`getServers(GetServersRequest request, StreamObserver<GetServersResponse> responseObserver)`	Returns servers.
`void`	ChannelzService.`getServerSockets(GetServerSocketsRequest request, StreamObserver<GetServerSocketsResponse> responseObserver)`
`void`	ChannelzService.`getSocket(GetSocketRequest request, StreamObserver<GetSocketResponse> responseObserver)`	Returns a socket.
`void`	ChannelzService.`getSubchannel(GetSubchannelRequest request, StreamObserver<GetSubchannelResponse> responseObserver)`	Returns a subchannel.
`void`	ChannelzService.`getTopChannels(GetTopChannelsRequest request, StreamObserver<GetTopChannelsResponse> responseObserver)`	Returns top level channel aka `ManagedChannel`.
`StreamObserver<ServerReflectionRequest>`	ProtoReflectionServiceV1.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`

Uses of StreamObserver in io.grpc.reflection.v1

Methods in io.grpc.reflection.v1 that return StreamObserver
Modifier and Type	Method	Description
`default StreamObserver<ServerReflectionRequest>`	ServerReflectionGrpc.AsyncService.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`	The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.
`StreamObserver<ServerReflectionRequest>`	ServerReflectionGrpc.ServerReflectionStub.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`	The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.

Methods in io.grpc.reflection.v1 with parameters of type StreamObserver
Modifier and Type	Method	Description
`default StreamObserver<ServerReflectionRequest>`	ServerReflectionGrpc.AsyncService.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`	The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.
`StreamObserver<ServerReflectionRequest>`	ServerReflectionGrpc.ServerReflectionStub.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`	The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.

Uses of StreamObserver in io.grpc.reflection.v1alpha

Methods in io.grpc.reflection.v1alpha that return StreamObserver
Modifier and Type	Method	Description
`default StreamObserver<ServerReflectionRequest>`	ServerReflectionGrpc.AsyncService.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`	The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.
`StreamObserver<ServerReflectionRequest>`	ServerReflectionGrpc.ServerReflectionStub.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`	The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.

Methods in io.grpc.reflection.v1alpha with parameters of type StreamObserver
Modifier and Type	Method	Description
`default StreamObserver<ServerReflectionRequest>`	ServerReflectionGrpc.AsyncService.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`	The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.
`StreamObserver<ServerReflectionRequest>`	ServerReflectionGrpc.ServerReflectionStub.`serverReflectionInfo(StreamObserver<ServerReflectionResponse> responseObserver)`	The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server.

Uses of StreamObserver in io.grpc.services

Methods in io.grpc.services with parameters of type StreamObserver
Modifier and Type	Method	Description
`void`	ChannelzService.`getChannel(GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver)`	Deprecated. Returns a top level channel aka `ManagedChannel`.
`void`	ChannelzService.`getServer(GetServerRequest request, StreamObserver<GetServerResponse> responseObserver)`	Deprecated. Returns a server.
`void`	ChannelzService.`getServers(GetServersRequest request, StreamObserver<GetServersResponse> responseObserver)`	Deprecated. Returns servers.
`void`	ChannelzService.`getServerSockets(GetServerSocketsRequest request, StreamObserver<GetServerSocketsResponse> responseObserver)`	Deprecated.
`void`	ChannelzService.`getSocket(GetSocketRequest request, StreamObserver<GetSocketResponse> responseObserver)`	Deprecated. Returns a socket.
`void`	ChannelzService.`getSubchannel(GetSubchannelRequest request, StreamObserver<GetSubchannelResponse> responseObserver)`	Deprecated. Returns a subchannel.
`void`	ChannelzService.`getTopChannels(GetTopChannelsRequest request, StreamObserver<GetTopChannelsResponse> responseObserver)`	Deprecated. Returns top level channel aka `ManagedChannel`.

Uses of StreamObserver in io.grpc.stub

Subinterfaces of StreamObserver in io.grpc.stub
Modifier and Type	Interface	Description
`interface`	`ClientResponseObserver<ReqT,RespT>`	Specialization of `StreamObserver` implemented by clients in order to interact with the advanced features of a call such as flow-control.

Classes in io.grpc.stub that implement StreamObserver
Modifier and Type	Class	Description
`class`	`CallStreamObserver<V>`	A refinement of StreamObserver provided by the GRPC runtime to the application (the client or the server) that allows for more complex interactions with call behavior.
`class`	`ClientCallStreamObserver<ReqT>`	A refinement of `CallStreamObserver` that allows for lower-level interaction with client calls.
`class`	`ServerCallStreamObserver<RespT>`	A refinement of `CallStreamObserver` to allows for interaction with call cancellation events on the server side.

Methods in io.grpc.stub that return StreamObserver
Modifier and Type	Method	Description
`static <ReqT,RespT> StreamObserver<ReqT>`	ClientCalls.`asyncBidiStreamingCall(ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)`	Executes a bidirectional-streaming call.
`static <ReqT,RespT> StreamObserver<ReqT>`	ClientCalls.`asyncClientStreamingCall(ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)`	Executes a client-streaming call returning a `StreamObserver` for the request messages.
`static <ReqT> StreamObserver<ReqT>`	ServerCalls.`asyncUnimplementedStreamingCall(MethodDescriptor<?,?> methodDescriptor, StreamObserver<?> responseObserver)`	Sets unimplemented status for streaming call.
`StreamObserver<ReqT>`	ServerCalls.BidiStreamingMethod.`invoke(StreamObserver<RespT> responseObserver)`
`StreamObserver<ReqT>`	ServerCalls.ClientStreamingMethod.`invoke(StreamObserver<RespT> responseObserver)`

Methods in io.grpc.stub with parameters of type StreamObserver
Modifier and Type	Method	Description
`static <ReqT,RespT> StreamObserver<ReqT>`	ClientCalls.`asyncBidiStreamingCall(ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)`	Executes a bidirectional-streaming call.
`static <ReqT,RespT> StreamObserver<ReqT>`	ClientCalls.`asyncClientStreamingCall(ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)`	Executes a client-streaming call returning a `StreamObserver` for the request messages.
`static <ReqT,RespT> void`	ClientCalls.`asyncServerStreamingCall(ClientCall<ReqT,RespT> call, ReqT req, StreamObserver<RespT> responseObserver)`	Executes a server-streaming call with a response `StreamObserver`.
`static <ReqT,RespT> void`	ClientCalls.`asyncUnaryCall(ClientCall<ReqT,RespT> call, ReqT req, StreamObserver<RespT> responseObserver)`	Executes a unary call with a response `StreamObserver`.
`static <ReqT> StreamObserver<ReqT>`	ServerCalls.`asyncUnimplementedStreamingCall(MethodDescriptor<?,?> methodDescriptor, StreamObserver<?> responseObserver)`	Sets unimplemented status for streaming call.
`static void`	ServerCalls.`asyncUnimplementedUnaryCall(MethodDescriptor<?,?> methodDescriptor, StreamObserver<?> responseObserver)`	Sets unimplemented status for method on given response stream for unary call.
`StreamObserver<ReqT>`	ServerCalls.BidiStreamingMethod.`invoke(StreamObserver<RespT> responseObserver)`
`StreamObserver<ReqT>`	ServerCalls.ClientStreamingMethod.`invoke(StreamObserver<RespT> responseObserver)`
`void`	ServerCalls.ServerStreamingMethod.`invoke(ReqT request, StreamObserver<RespT> responseObserver)`
`void`	ServerCalls.UnaryMethod.`invoke(ReqT request, StreamObserver<RespT> responseObserver)`
`static <T> void`	StreamObservers.`nextAndComplete(StreamObserver<T> responseObserver, T response)`	Utility method to call `onNext(Object)` and `onCompleted()` on the specified responseObserver.

Uses of StreamObserver in io.grpc.testing

Classes in io.grpc.testing that implement StreamObserver
Modifier and Type Class Description

class StreamRecorder<T>
Deprecated.
Not for public use