| 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<ReqT>
A refinement of
CallStreamObserver that allows for lower-level interaction with
client calls. |
class |
ServerCallStreamObserver<RespT>
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 <ReqT> StreamObserver<ReqT> |
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 <ReqT> StreamObserver<ReqT> |
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) |