Package | Description |
---|---|
io.grpc |
The gRPC core public API.
|
io.grpc.auth |
Implementations of
CallCredentials and authentication related API. |
io.grpc.stub |
API for the Stub layer.
|
Modifier and Type | Class and Description |
---|---|
static class |
ClientInterceptors.CheckedForwardingClientCall<ReqT,RespT>
A
ForwardingClientCall that delivers exceptions from its start logic to the
call listener. |
class |
ForwardingClientCall<ReqT,RespT>
A
ClientCall which forwards all of its methods to another ClientCall . |
static class |
ForwardingClientCall.SimpleForwardingClientCall<ReqT,RespT>
A simplified version of
ForwardingClientCall where subclasses can pass in a ClientCall as the delegate. |
Modifier and Type | Method and Description |
---|---|
protected ClientCall<ReqT,RespT> |
ClientInterceptors.CheckedForwardingClientCall.delegate() |
protected abstract ClientCall<ReqT,RespT> |
ForwardingClientCall.delegate()
Returns the delegated
ClientCall . |
protected ClientCall<ReqT,RespT> |
ForwardingClientCall.SimpleForwardingClientCall.delegate() |
<ReqT,RespT> |
ClientInterceptor.interceptCall(MethodDescriptor<ReqT,RespT> method,
CallOptions callOptions,
Channel next)
|
abstract <RequestT,ResponseT> |
Channel.newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor,
CallOptions callOptions)
Create a
ClientCall to the remote operation specified by the given
MethodDescriptor . |
Constructor and Description |
---|
CheckedForwardingClientCall(ClientCall<ReqT,RespT> delegate) |
SimpleForwardingClientCall(ClientCall<ReqT,RespT> delegate) |
Modifier and Type | Method and Description |
---|---|
<ReqT,RespT> |
ClientAuthInterceptor.interceptCall(MethodDescriptor<ReqT,RespT> method,
CallOptions callOptions,
Channel next)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <ReqT,RespT> |
ClientCalls.asyncBidiStreamingCall(ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a bidirectional-streaming call.
|
static <ReqT,RespT> |
ClientCalls.asyncClientStreamingCall(ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a client-streaming call returning a
StreamObserver for the request messages. |
static <ReqT,RespT> |
ClientCalls.asyncServerStreamingCall(ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
Executes a server-streaming call with a response
StreamObserver . |
static <ReqT,RespT> |
ClientCalls.asyncUnaryCall(ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
Executes a unary call with a response
StreamObserver . |
static <ReqT,RespT> |
ClientCalls.blockingServerStreamingCall(ClientCall<ReqT,RespT> call,
ReqT req)
Executes a server-streaming call returning a blocking
Iterator over the
response stream. |
static <ReqT,RespT> |
ClientCalls.blockingUnaryCall(ClientCall<ReqT,RespT> call,
ReqT req)
Executes a unary call and blocks on the response.
|
static <ReqT,RespT> |
ClientCalls.futureUnaryCall(ClientCall<ReqT,RespT> call,
ReqT req)
Executes a unary call and returns a
ListenableFuture to the response. |