Uses of Class
io.grpc.ClientCall
-
Packages that use ClientCall Package Description io.grpc The gRPC core public API.io.grpc.internal Interfaces and implementations that are internal to gRPC.io.grpc.protobuf.services Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.io.grpc.stub API for the Stub layer. -
-
Uses of ClientCall in io.grpc
Subclasses of ClientCall in io.grpc Modifier and Type Class Description static class
ClientInterceptors.CheckedForwardingClientCall<ReqT,RespT>
AForwardingClientCall
that delivers exceptions from its start logic to the call listener.class
ForwardingClientCall<ReqT,RespT>
AClientCall
which forwards all of its methods to anotherClientCall
.static class
ForwardingClientCall.SimpleForwardingClientCall<ReqT,RespT>
A simplified version ofForwardingClientCall
where subclasses can pass in aClientCall
as the delegate.(package private) class
PartialForwardingClientCall<ReqT,RespT>
AClientCall
which forwards all of its methods to anotherClientCall
which may have a different sendMessage() message type.Fields in io.grpc declared as ClientCall Modifier and Type Field Description private ClientCall<ReqT,RespT>
ClientInterceptors.CheckedForwardingClientCall. delegate
private ClientCall<ReqT,RespT>
ForwardingClientCall.SimpleForwardingClientCall. delegate
private static ClientCall<java.lang.Object,java.lang.Object>
ClientInterceptors. NOOP_CALL
Methods in io.grpc that return ClientCall Modifier and Type Method Description protected ClientCall<ReqT,RespT>
ClientInterceptors.CheckedForwardingClientCall. delegate()
protected abstract ClientCall<ReqT,RespT>
ForwardingClientCall. delegate()
Returns the delegatedClientCall
.protected ClientCall<ReqT,RespT>
ForwardingClientCall.SimpleForwardingClientCall. delegate()
protected abstract ClientCall<?,?>
PartialForwardingClientCall. delegate()
Returns the delegatedClientCall
.<ReqT,RespT>
ClientCall<ReqT,RespT>ClientInterceptor. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next)
abstract <RequestT,ResponseT>
ClientCall<RequestT,ResponseT>Channel. newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)
Create aClientCall
to the remote operation specified by the givenMethodDescriptor
.<ReqT,RespT>
ClientCall<ReqT,RespT>ClientInterceptors.InterceptorChannel. newCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)
Constructors in io.grpc with parameters of type ClientCall Constructor Description CheckedForwardingClientCall(ClientCall<ReqT,RespT> delegate)
SimpleForwardingClientCall(ClientCall<ReqT,RespT> delegate)
-
Uses of ClientCall in io.grpc.internal
Subclasses of ClientCall in io.grpc.internal Modifier and Type Class Description (package private) class
ClientCallImpl<ReqT,RespT>
Implementation ofClientCall
.class
DelayedClientCall<ReqT,RespT>
A call that queues requests before a real call is ready to be delegated to.(package private) static class
ManagedChannelImpl.ConfigSelectingClientCall<ReqT,RespT>
A client call for a given channel that applies a given config selector when it starts.private class
ManagedChannelImpl.RealChannel.PendingCall<ReqT,RespT>
Fields in io.grpc.internal declared as ClientCall Modifier and Type Field Description private ClientCall<ReqT,RespT>
ManagedChannelImpl.ConfigSelectingClientCall. delegate
private static ClientCall<java.lang.Object,java.lang.Object>
DelayedClientCall. NOOP_CALL
private static ClientCall<java.lang.Object,java.lang.Object>
ManagedChannelImpl. NOOP_CALL
private ClientCall<ReqT,RespT>
DelayedClientCall. realCall
Methods in io.grpc.internal that return ClientCall Modifier and Type Method Description protected ClientCall<ReqT,RespT>
ManagedChannelImpl.ConfigSelectingClientCall. delegate()
(package private) ClientCall<ReqT,RespT>
DelayedClientCall. getRealCall()
<ReqT,RespT>
ClientCall<ReqT,RespT>ManagedChannelImplBuilder.InterceptorFactoryWrapper. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next)
<RequestT,ResponseT>
ClientCall<RequestT,ResponseT>ForwardingManagedChannel. newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)
<ReqT,RespT>
ClientCall<ReqT,RespT>ManagedChannelImpl. newCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)
<ReqT,RespT>
ClientCall<ReqT,RespT>ManagedChannelImpl.RealChannel. newCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)
<RequestT,ResponseT>
ClientCall<RequestT,ResponseT>OobChannel. newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)
<RequestT,ResponseT>
ClientCall<RequestT,ResponseT>SubchannelChannel. newCall(MethodDescriptor<RequestT,ResponseT> methodDescriptor, CallOptions callOptions)
private <ReqT,RespT>
ClientCall<ReqT,RespT>ManagedChannelImpl.RealChannel. newClientCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)
Methods in io.grpc.internal with parameters of type ClientCall Modifier and Type Method Description java.lang.Runnable
DelayedClientCall. setCall(ClientCall<ReqT,RespT> call)
Transfers all pending and future requests and mutations to the given call.private void
DelayedClientCall. setRealCall(ClientCall<ReqT,RespT> realCall)
-
Uses of ClientCall in io.grpc.protobuf.services
Fields in io.grpc.protobuf.services declared as ClientCall Modifier and Type Field Description private ClientCall<HealthCheckRequest,HealthCheckResponse>
HealthCheckingLoadBalancerFactory.HealthCheckState.HcStream. call
Methods in io.grpc.protobuf.services that return ClientCall Modifier and Type Method Description <ReqT,RespT>
ClientCall<ReqT,RespT>BinaryLogProvider.BinaryLogShim. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next)
-
Uses of ClientCall in io.grpc.stub
Subclasses of ClientCall in io.grpc.stub Modifier and Type Class Description private class
MetadataUtils.HeaderAttachingClientInterceptor.HeaderAttachingClientCall<ReqT,RespT>
private class
MetadataUtils.MetadataCapturingClientInterceptor.MetadataCapturingClientCall<ReqT,RespT>
Fields in io.grpc.stub declared as ClientCall Modifier and Type Field Description private ClientCall<?,T>
ClientCalls.BlockingResponseStream. call
private ClientCall<ReqT,?>
ClientCalls.CallToStreamObserverAdapter. call
private ClientCall<?,RespT>
ClientCalls.GrpcFuture. call
Methods in io.grpc.stub that return ClientCall Modifier and Type Method Description <ReqT,RespT>
ClientCall<ReqT,RespT>MetadataUtils.HeaderAttachingClientInterceptor. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next)
<ReqT,RespT>
ClientCall<ReqT,RespT>MetadataUtils.MetadataCapturingClientInterceptor. interceptCall(MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, Channel next)
Methods in io.grpc.stub with parameters of type ClientCall 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, ClientCalls.StartableListener<RespT> responseListener)
private static <ReqT,RespT>
voidClientCalls. asyncUnaryRequestCall(ClientCall<ReqT,RespT> call, ReqT req, StreamObserver<RespT> responseObserver, boolean streamingResponse)
static <ReqT,RespT>
java.util.Iterator<RespT>ClientCalls. blockingServerStreamingCall(ClientCall<ReqT,RespT> call, ReqT req)
Executes a server-streaming call returning a blockingIterator
over the response stream.static <ReqT,RespT>
RespTClientCalls. blockingUnaryCall(ClientCall<ReqT,RespT> call, ReqT req)
Executes a unary call and blocks on the response.private static java.lang.RuntimeException
ClientCalls. cancelThrow(ClientCall<?,?> call, java.lang.Throwable t)
Cancels a call, and throws the exception.static <ReqT,RespT>
com.google.common.util.concurrent.ListenableFuture<RespT>ClientCalls. futureUnaryCall(ClientCall<ReqT,RespT> call, ReqT req)
Executes a unary call and returns aListenableFuture
to the response.private static <ReqT,RespT>
voidClientCalls. startCall(ClientCall<ReqT,RespT> call, ClientCalls.StartableListener<RespT> responseListener)
Constructors in io.grpc.stub with parameters of type ClientCall Constructor Description BlockingResponseStream(ClientCall<?,T> call)
CallToStreamObserverAdapter(ClientCall<ReqT,?> call, boolean streamingResponse)
GrpcFuture(ClientCall<?,RespT> call)
HeaderAttachingClientCall(ClientCall<ReqT,RespT> call)
MetadataCapturingClientCall(ClientCall<ReqT,RespT> call)
-