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 classClientInterceptors.CheckedForwardingClientCall<ReqT,RespT> AForwardingClientCallthat delivers exceptions from its start logic to the call listener.classForwardingClientCall<ReqT,RespT> AClientCallwhich forwards all of its methods to anotherClientCall.static classForwardingClientCall.SimpleForwardingClientCall<ReqT,RespT> A simplified version ofForwardingClientCallwhere subclasses can pass in aClientCallas the delegate.(package private) classPartialForwardingClientCall<ReqT,RespT> AClientCallwhich forwards all of its methods to anotherClientCallwhich may have a different sendMessage() message type.Fields in io.grpc declared as ClientCallModifier and TypeFieldDescriptionprivate ClientCall<ReqT, RespT> ClientInterceptors.CheckedForwardingClientCall.delegateprivate final ClientCall<ReqT, RespT> ForwardingClientCall.SimpleForwardingClientCall.delegateprivate static final ClientCall<Object, Object> ClientInterceptors.NOOP_CALLMethods 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 aClientCallto 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 ClientCallModifierConstructorDescriptionprotectedCheckedForwardingClientCall(ClientCall<ReqT, RespT> delegate) protectedSimpleForwardingClientCall(ClientCall<ReqT, RespT> delegate) -
Uses of ClientCall in io.grpc.internal
Subclasses of ClientCall in io.grpc.internalModifier and TypeClassDescription(package private) final classClientCallImpl<ReqT,RespT> Implementation ofClientCall.classDelayedClientCall<ReqT,RespT> A call that queues requests before a real call is ready to be delegated to.(package private) static final classManagedChannelImpl.ConfigSelectingClientCall<ReqT,RespT> A client call for a given channel that applies a given config selector when it starts.private final classManagedChannelImpl.RealChannel.PendingCall<ReqT,RespT> Fields in io.grpc.internal declared as ClientCallModifier and TypeFieldDescriptionprivate ClientCall<ReqT, RespT> ManagedChannelImpl.ConfigSelectingClientCall.delegateprivate static final ClientCall<Object, Object> DelayedClientCall.NOOP_CALLprivate static final ClientCall<Object, Object> ManagedChannelImpl.NOOP_CALLprivate ClientCall<ReqT, RespT> DelayedClientCall.realCallMethods 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 RunnableDelayedClientCall.setCall(ClientCall<ReqT, RespT> call) Transfers all pending and future requests and mutations to the given call.private voidDelayedClientCall.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.callMethods 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 classprivate final classFields in io.grpc.stub declared as ClientCallModifier and TypeFieldDescriptionprivate final ClientCall<?, T> ClientCalls.BlockingResponseStream.callprivate final ClientCall<ReqT, ?> ClientCalls.CallToStreamObserverAdapter.callprivate final ClientCall<?, RespT> ClientCalls.GrpcFuture.callMethods 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 aStreamObserverfor 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 blockingIteratorover 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 RuntimeExceptionClientCalls.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 aListenableFutureto 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)