Package | Description |
---|---|
io.grpc.stub |
API for the Stub layer.
|
Modifier and Type | Interface and 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. |
Modifier and Type | Class and 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<V>
A refinement of
CallStreamObserver that allows for lower-level interaction with
client calls. |
class |
ServerCallStreamObserver<V>
A refinement of
CallStreamObserver to allows for interaction with call
cancellation events on the server side. |
Modifier and Type | Method and Description |
---|---|
static <ReqT,RespT> |
ClientCalls.asyncBidiStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a bidirectional-streaming call.
|
static <ReqT,RespT> |
ClientCalls.asyncClientStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a client-streaming call returning a
StreamObserver for the request messages. |
static <T> StreamObserver<T> |
ServerCalls.asyncUnimplementedStreamingCall(io.grpc.MethodDescriptor<?,?> methodDescriptor,
StreamObserver<?> responseObserver)
Sets unimplemented status for streaming call.
|
StreamObserver<ReqT> |
ServerCalls.ClientStreamingMethod.invoke(StreamObserver<RespT> responseObserver) |
StreamObserver<ReqT> |
ServerCalls.BidiStreamingMethod.invoke(StreamObserver<RespT> responseObserver) |
Modifier and Type | Method and Description |
---|---|
static <ReqT,RespT> |
ClientCalls.asyncBidiStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a bidirectional-streaming call.
|
static <ReqT,RespT> |
ClientCalls.asyncClientStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a client-streaming call returning a
StreamObserver for the request messages. |
static <ReqT,RespT> |
ClientCalls.asyncServerStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
Executes a server-streaming call with a response
StreamObserver . |
static <ReqT,RespT> |
ClientCalls.asyncUnaryCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
Executes a unary call with a response
StreamObserver . |
static <T> StreamObserver<T> |
ServerCalls.asyncUnimplementedStreamingCall(io.grpc.MethodDescriptor<?,?> methodDescriptor,
StreamObserver<?> responseObserver)
Sets unimplemented status for streaming call.
|
static void |
ServerCalls.asyncUnimplementedUnaryCall(io.grpc.MethodDescriptor<?,?> methodDescriptor,
StreamObserver<?> responseObserver)
Sets unimplemented status for method on given response stream for unary call.
|
void |
ServerCalls.UnaryMethod.invoke(ReqT request,
StreamObserver<RespT> responseObserver) |
void |
ServerCalls.ServerStreamingMethod.invoke(ReqT request,
StreamObserver<RespT> responseObserver) |
StreamObserver<ReqT> |
ServerCalls.ClientStreamingMethod.invoke(StreamObserver<RespT> responseObserver) |
StreamObserver<ReqT> |
ServerCalls.BidiStreamingMethod.invoke(StreamObserver<RespT> responseObserver) |