Uses of Interface
io.grpc.stub.StreamObserver

Packages that use StreamObserver

Package	Description
io.grpc.channelz.v1
io.grpc.grpclb
io.grpc.health.v1
io.grpc.lb.v1
io.grpc.lookup.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.

Uses of StreamObserver in io.grpc.channelz.v1

Methods in io.grpc.channelz.v1 that return StreamObserver

Modifier and Type	Method	Description
StreamObserver<Req>	ChannelzGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)

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.
StreamObserver<Req>	ChannelzGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)
void	ChannelzGrpc.MethodHandlers.invoke(Req request, StreamObserver<Resp> responseObserver)

Uses of StreamObserver in io.grpc.grpclb

Classes in io.grpc.grpclb that implement StreamObserver

Modifier and Type	Class	Description
private class	GrpclbState.LbStream

Fields in io.grpc.grpclb declared as StreamObserver

Modifier and Type	Field	Description
(package private) StreamObserver<LoadBalanceRequest>	GrpclbState.LbStream.lbRequestWriter

Uses of StreamObserver in io.grpc.health.v1

Methods in io.grpc.health.v1 that return StreamObserver

Modifier and Type	Method	Description
StreamObserver<Req>	HealthGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)

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.
StreamObserver<Req>	HealthGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)
void	HealthGrpc.MethodHandlers.invoke(Req request, StreamObserver<Resp> responseObserver)
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.
StreamObserver<Req>	LoadBalancerGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)

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.
StreamObserver<Req>	LoadBalancerGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)
void	LoadBalancerGrpc.MethodHandlers.invoke(Req request, StreamObserver<Resp> responseObserver)

Uses of StreamObserver in io.grpc.lookup.v1

Methods in io.grpc.lookup.v1 that return StreamObserver

Modifier and Type	Method	Description
StreamObserver<Req>	RouteLookupServiceGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)

Methods in io.grpc.lookup.v1 with parameters of type StreamObserver

Modifier and Type	Method	Description
StreamObserver<Req>	RouteLookupServiceGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)
void	RouteLookupServiceGrpc.MethodHandlers.invoke(Req request, StreamObserver<Resp> responseObserver)
default void	RouteLookupServiceGrpc.AsyncService.routeLookup(RouteLookupRequest request, StreamObserver<RouteLookupResponse> responseObserver)	Lookup returns a target for a single key.
void	RouteLookupServiceGrpc.RouteLookupServiceStub.routeLookup(RouteLookupRequest request, StreamObserver<RouteLookupResponse> responseObserver)	Lookup returns a target for a single key.

Uses of StreamObserver in io.grpc.protobuf.services

Classes in io.grpc.protobuf.services that implement StreamObserver

Modifier and Type	Class	Description
private static class	ProtoReflectionServiceV1.ProtoReflectionStreamObserver

Fields in io.grpc.protobuf.services with type parameters of type StreamObserver

Modifier and Type	Field	Description
private final HashMap<String,IdentityHashMap<StreamObserver<HealthCheckResponse>,Boolean>>	HealthServiceImpl.watchers

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	HealthServiceImpl.check(HealthCheckRequest request, StreamObserver<HealthCheckResponse> responseObserver)
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)
void	HealthServiceImpl.watch(HealthCheckRequest request, StreamObserver<HealthCheckResponse> responseObserver)

Uses of StreamObserver in io.grpc.reflection.v1

Methods in io.grpc.reflection.v1 that return StreamObserver

Modifier and Type	Method	Description
StreamObserver<Req>	ServerReflectionGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)
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
StreamObserver<Req>	ServerReflectionGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)
void	ServerReflectionGrpc.MethodHandlers.invoke(Req request, StreamObserver<Resp> responseObserver)
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
StreamObserver<Req>	ServerReflectionGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)
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
StreamObserver<Req>	ServerReflectionGrpc.MethodHandlers.invoke(StreamObserver<Resp> responseObserver)
void	ServerReflectionGrpc.MethodHandlers.invoke(Req request, StreamObserver<Resp> responseObserver)
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.
private static final class	ClientCalls.CallToStreamObserverAdapter<ReqT>
class	ClientCallStreamObserver<ReqT>	A refinement of CallStreamObserver that allows for lower-level interaction with client calls.
(package private) static class	ServerCalls.NoopStreamObserver<V>	No-op implementation of StreamObserver.
private static final class	ServerCalls.ServerCallStreamObserverImpl<ReqT,RespT>
class	ServerCallStreamObserver<RespT>	A refinement of CallStreamObserver to allows for interaction with call cancellation events on the server side.

Fields in io.grpc.stub declared as StreamObserver

Modifier and Type	Field	Description
private final StreamObserver<RespT>	ClientCalls.StreamObserverToCallListenerAdapter.observer
private final StreamObserver<ReqT>	ServerCalls.StreamingServerCallHandler.StreamingServerCallListener.requestObserver

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.
private static <ReqT, RespT> StreamObserver<ReqT>	ClientCalls.asyncStreamingRequestCall(ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver, boolean streamingResponse)
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)
StreamObserver<ReqT>	ServerCalls.StreamingRequestMethod.invoke(StreamObserver<RespT> responseObserver)	The provided responseObserver will extend ServerCallStreamObserver.

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.
private static <ReqT, RespT> StreamObserver<ReqT>	ClientCalls.asyncStreamingRequestCall(ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver, boolean streamingResponse)
static <ReqT, RespT> void	ClientCalls.asyncUnaryCall(ClientCall<ReqT,RespT> call, ReqT req, StreamObserver<RespT> responseObserver)	Executes a unary call with a response StreamObserver.
private static <ReqT, RespT> void	ClientCalls.asyncUnaryRequestCall(ClientCall<ReqT,RespT> call, ReqT req, StreamObserver<RespT> responseObserver, boolean streamingResponse)
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)
StreamObserver<ReqT>	ServerCalls.StreamingRequestMethod.invoke(StreamObserver<RespT> responseObserver)	The provided responseObserver will extend ServerCallStreamObserver.
void	ServerCalls.UnaryMethod.invoke(ReqT request, StreamObserver<RespT> responseObserver)
void	ServerCalls.UnaryRequestMethod.invoke(ReqT request, StreamObserver<RespT> responseObserver)	The provided responseObserver will extend ServerCallStreamObserver.

Constructors in io.grpc.stub with parameters of type StreamObserver

Modifier	Constructor	Description
(package private)	StreamingServerCallListener(StreamObserver<ReqT> requestObserver, ServerCalls.ServerCallStreamObserverImpl<ReqT,RespT> responseObserver, ServerCall<ReqT,RespT> call)
(package private)	StreamObserverToCallListenerAdapter(StreamObserver<RespT> observer, ClientCalls.CallToStreamObserverAdapter<ReqT> adapter)