Uses of Class
io.grpc.ClientCall
Packages that use ClientCall
Package
Description
The gRPC core public API.
Interfaces and implementations that are internal to gRPC.
Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.
API for the Stub layer.
-
Uses of ClientCall in io.grpc
Subclasses of ClientCall in io.grpcModifier and TypeClassDescriptionstatic 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 ClientCallModifier and TypeFieldDescriptionprivate ClientCall
<ReqT, RespT> ClientInterceptors.CheckedForwardingClientCall.delegate
private final ClientCall
<ReqT, RespT> ForwardingClientCall.SimpleForwardingClientCall.delegate
private static final ClientCall
<Object, Object> ClientInterceptors.NOOP_CALL
Methods in io.grpc that return ClientCallModifier and TypeMethodDescriptionprotected final 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 ClientCallModifierConstructorDescriptionprotected
CheckedForwardingClientCall
(ClientCall<ReqT, RespT> delegate) protected
SimpleForwardingClientCall
(ClientCall<ReqT, RespT> delegate) -
Uses of ClientCall in io.grpc.internal
Subclasses of ClientCall in io.grpc.internalModifier and TypeClassDescription(package private) final 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 final class
ManagedChannelImpl.ConfigSelectingClientCall<ReqT,
RespT> A client call for a given channel that applies a given config selector when it starts.private final class
ManagedChannelImpl.RealChannel.PendingCall<ReqT,
RespT> Fields in io.grpc.internal declared as ClientCallModifier and TypeFieldDescriptionprivate ClientCall
<ReqT, RespT> ManagedChannelImpl.ConfigSelectingClientCall.delegate
private static final ClientCall
<Object, Object> DelayedClientCall.NOOP_CALL
private static final ClientCall
<Object, Object> ManagedChannelImpl.NOOP_CALL
private ClientCall
<ReqT, RespT> DelayedClientCall.realCall
Methods in io.grpc.internal that return ClientCallModifier and TypeMethodDescriptionprotected ClientCall
<ReqT, RespT> ManagedChannelImpl.ConfigSelectingClientCall.delegate()
(package private) final 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 ClientCallModifier and TypeMethodDescriptionfinal 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 ClientCallModifier and TypeFieldDescriptionprivate final ClientCall
<HealthCheckRequest, HealthCheckResponse> HealthCheckingLoadBalancerFactory.HealthCheckState.HcStream.call
Methods in io.grpc.protobuf.services that return ClientCallModifier and TypeMethodDescription<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.stubModifier and TypeClassDescriptionprivate final class
private final class
Fields in io.grpc.stub declared as ClientCallModifier and TypeFieldDescriptionprivate final ClientCall
<?, T> ClientCalls.BlockingResponseStream.call
private final ClientCall
<ReqT, ?> ClientCalls.CallToStreamObserverAdapter.call
private final ClientCall
<?, RespT> ClientCalls.GrpcFuture.call
Methods in io.grpc.stub that return ClientCallModifier and TypeMethodDescription<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 ClientCallModifier and TypeMethodDescriptionstatic <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>
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 RuntimeException
ClientCalls.cancelThrow
(ClientCall<?, ?> call, 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 ClientCallModifierConstructorDescription(package private)
BlockingResponseStream
(ClientCall<?, T> call) (package private)
CallToStreamObserverAdapter
(ClientCall<ReqT, ?> call, boolean streamingResponse) (package private)
GrpcFuture
(ClientCall<?, RespT> call) (package private)
(package private)