Package | Description |
---|---|
io.grpc.stub |
API for the Stub layer.
|
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. |
Modifier and Type | Class | Description |
---|---|---|
class |
CallStreamObserver<V> |
A refinement of StreamObserver provided by the GRPC runtime to the application 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 | 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.
|
Modifier and Type | Method | 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.
|