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 java.util.HashMap<java.lang.String,java.util.IdentityHashMap<StreamObserver<HealthCheckResponse>,java.lang.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 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
.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 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.stub Modifier and Type Interface Description interface
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 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 class
ClientCalls.CallToStreamObserverAdapter<ReqT>
class
ClientCallStreamObserver<ReqT>
A refinement ofCallStreamObserver
that allows for lower-level interaction with client calls.(package private) static class
ServerCalls.NoopStreamObserver<V>
No-op implementation of StreamObserver.private static 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 StreamObserver Modifier and Type Field Description private StreamObserver<RespT>
ClientCalls.StreamObserverToCallListenerAdapter. observer
private 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 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.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 providedresponseObserver
will extendServerCallStreamObserver
.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 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.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 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 StreamObserver Constructor Description StreamingServerCallListener(StreamObserver<ReqT> requestObserver, ServerCalls.ServerCallStreamObserverImpl<ReqT,RespT> responseObserver, ServerCall<ReqT,RespT> call)
StreamObserverToCallListenerAdapter(StreamObserver<RespT> observer, ClientCalls.CallToStreamObserverAdapter<ReqT> adapter)
-