Uses of Interface
io.grpc.stub.StreamObserver
Packages that use StreamObserver
Package
Description
Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.
Service definitions and utilities for the pre-defined gRPC services.
API for the Stub layer.
-
Uses of StreamObserver in io.grpc.channelz.v1
Methods in io.grpc.channelz.v1 that return StreamObserverModifier and TypeMethodDescriptionChannelzGrpc.MethodHandlers.invoke
(StreamObserver<Resp> responseObserver) Methods in io.grpc.channelz.v1 with parameters of type StreamObserverModifier and TypeMethodDescriptiondefault 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.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 StreamObserverFields in io.grpc.grpclb declared as StreamObserverModifier and TypeFieldDescription(package private) StreamObserver
<LoadBalanceRequest> GrpclbState.LbStream.lbRequestWriter
-
Uses of StreamObserver in io.grpc.health.v1
Methods in io.grpc.health.v1 that return StreamObserverModifier and TypeMethodDescriptionHealthGrpc.MethodHandlers.invoke
(StreamObserver<Resp> responseObserver) Methods in io.grpc.health.v1 with parameters of type StreamObserverModifier and TypeMethodDescriptiondefault 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.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 StreamObserverModifier and TypeMethodDescriptiondefault StreamObserver
<LoadBalanceRequest> LoadBalancerGrpc.AsyncService.balanceLoad
(StreamObserver<LoadBalanceResponse> responseObserver) Bidirectional rpc to get a list of servers.LoadBalancerGrpc.LoadBalancerStub.balanceLoad
(StreamObserver<LoadBalanceResponse> responseObserver) Bidirectional rpc to get a list of servers.LoadBalancerGrpc.MethodHandlers.invoke
(StreamObserver<Resp> responseObserver) Methods in io.grpc.lb.v1 with parameters of type StreamObserverModifier and TypeMethodDescriptiondefault StreamObserver
<LoadBalanceRequest> LoadBalancerGrpc.AsyncService.balanceLoad
(StreamObserver<LoadBalanceResponse> responseObserver) Bidirectional rpc to get a list of servers.LoadBalancerGrpc.LoadBalancerStub.balanceLoad
(StreamObserver<LoadBalanceResponse> responseObserver) Bidirectional rpc to get a list of servers.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 StreamObserverModifier and TypeMethodDescriptionRouteLookupServiceGrpc.MethodHandlers.invoke
(StreamObserver<Resp> responseObserver) Methods in io.grpc.lookup.v1 with parameters of type StreamObserverModifier and TypeMethodDescriptionRouteLookupServiceGrpc.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 StreamObserverModifier and TypeClassDescriptionprivate static class
Fields in io.grpc.protobuf.services with type parameters of type StreamObserverModifier and TypeFieldDescriptionprivate final HashMap
<String, IdentityHashMap<StreamObserver<HealthCheckResponse>, Boolean>> HealthServiceImpl.watchers
Methods in io.grpc.protobuf.services that return StreamObserverModifier and TypeMethodDescriptionProtoReflectionServiceV1.serverReflectionInfo
(StreamObserver<ServerReflectionResponse> responseObserver) Methods in io.grpc.protobuf.services with parameters of type StreamObserverModifier and TypeMethodDescriptionvoid
HealthServiceImpl.check
(HealthCheckRequest request, StreamObserver<HealthCheckResponse> responseObserver) void
ChannelzService.getChannel
(GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver) Returns a top level channel akaManagedChannel
.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 akaManagedChannel
.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 StreamObserverModifier and TypeMethodDescriptionServerReflectionGrpc.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.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 StreamObserverModifier and TypeMethodDescriptionServerReflectionGrpc.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.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 StreamObserverModifier and TypeMethodDescriptionServerReflectionGrpc.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.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 StreamObserverModifier and TypeMethodDescriptionServerReflectionGrpc.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.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 StreamObserverModifier and TypeMethodDescriptionvoid
ChannelzService.getChannel
(GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver) Deprecated.Returns a top level channel akaManagedChannel
.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 akaManagedChannel
. -
Uses of StreamObserver in io.grpc.stub
Subinterfaces of StreamObserver in io.grpc.stubModifier and TypeInterfaceDescriptioninterface
ClientResponseObserver<ReqT,
RespT> Specialization ofStreamObserver
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 StreamObserverModifier and TypeClassDescriptionclass
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
class
ClientCallStreamObserver<ReqT>
A refinement ofCallStreamObserver
that allows for lower-level interaction with client calls.(package private) static class
No-op implementation of StreamObserver.private static final class
ServerCalls.ServerCallStreamObserverImpl<ReqT,
RespT> class
ServerCallStreamObserver<RespT>
A refinement ofCallStreamObserver
to allows for interaction with call cancellation events on the server side.Fields in io.grpc.stub declared as StreamObserverModifier and TypeFieldDescriptionprivate final StreamObserver
<RespT> ClientCalls.StreamObserverToCallListenerAdapter.observer
private final StreamObserver
<ReqT> ServerCalls.StreamingServerCallHandler.StreamingServerCallListener.requestObserver
Methods in io.grpc.stub that return StreamObserverModifier and TypeMethodDescriptionstatic <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 aStreamObserver
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.ServerCalls.BidiStreamingMethod.invoke
(StreamObserver<RespT> responseObserver) ServerCalls.ClientStreamingMethod.invoke
(StreamObserver<RespT> responseObserver) ServerCalls.StreamingRequestMethod.invoke
(StreamObserver<RespT> responseObserver) The providedresponseObserver
will extendServerCallStreamObserver
.Methods in io.grpc.stub with parameters of type StreamObserverModifier and TypeMethodDescriptionstatic <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 aStreamObserver
for the request messages.static <ReqT,
RespT>
voidClientCalls.asyncServerStreamingCall
(ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) Executes a server-streaming call with a responseStreamObserver
.private static <ReqT,
RespT>
StreamObserver<ReqT> ClientCalls.asyncStreamingRequestCall
(ClientCall<ReqT, RespT> call, StreamObserver<RespT> responseObserver, boolean streamingResponse) static <ReqT,
RespT>
voidClientCalls.asyncUnaryCall
(ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) Executes a unary call with a responseStreamObserver
.private static <ReqT,
RespT>
voidClientCalls.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.ServerCalls.BidiStreamingMethod.invoke
(StreamObserver<RespT> responseObserver) ServerCalls.ClientStreamingMethod.invoke
(StreamObserver<RespT> responseObserver) void
ServerCalls.ServerStreamingMethod.invoke
(ReqT request, StreamObserver<RespT> responseObserver) ServerCalls.StreamingRequestMethod.invoke
(StreamObserver<RespT> responseObserver) The providedresponseObserver
will extendServerCallStreamObserver
.void
ServerCalls.UnaryMethod.invoke
(ReqT request, StreamObserver<RespT> responseObserver) void
ServerCalls.UnaryRequestMethod.invoke
(ReqT request, StreamObserver<RespT> responseObserver) The providedresponseObserver
will extendServerCallStreamObserver
.Constructors in io.grpc.stub with parameters of type StreamObserverModifierConstructorDescription(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)