public final class ClientCalls
extends java.lang.Object
| Modifier and Type | Method and Description |
|---|---|
static <ReqT,RespT> |
asyncBidiStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
StreamObserver<RespT> responseObserver)
Executes a bidirectional-streaming call.
|
static <ReqT,RespT> |
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> |
asyncServerStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
Executes a server-streaming call with a response
StreamObserver. |
static <ReqT,RespT> |
asyncUnaryCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
Executes a unary call with a response
StreamObserver. |
static <ReqT,RespT> |
blockingServerStreamingCall(io.grpc.Channel channel,
io.grpc.MethodDescriptor<ReqT,RespT> method,
io.grpc.CallOptions callOptions,
ReqT req)
Executes a server-streaming call returning a blocking
Iterator over the
response stream. |
static <ReqT,RespT> |
blockingServerStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req)
Executes a server-streaming call returning a blocking
Iterator over the
response stream. |
static <ReqT,RespT> |
blockingUnaryCall(io.grpc.Channel channel,
io.grpc.MethodDescriptor<ReqT,RespT> method,
io.grpc.CallOptions callOptions,
ReqT req)
Executes a unary call and blocks on the response.
|
static <ReqT,RespT> |
blockingUnaryCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req)
Executes a unary call and blocks on the response.
|
static <ReqT,RespT> |
futureUnaryCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req)
Executes a unary call and returns a
ListenableFuture to the response. |
public static <ReqT,RespT> void asyncUnaryCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
StreamObserver. The call should not be
already started. After calling this method, call should no longer be used.
If the provided responseObserver is an instance of ClientResponseObserver,
beforeStart() will be called.
public static <ReqT,RespT> void asyncServerStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req,
StreamObserver<RespT> responseObserver)
StreamObserver. The call
should not be already started. After calling this method, call should no longer be
used.
If the provided responseObserver is an instance of ClientResponseObserver,
beforeStart() will be called.
public static <ReqT,RespT> StreamObserver<ReqT> asyncClientStreamingCall(io.grpc.ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)
StreamObserver for the request messages.
The call should not be already started. After calling this method, call
should no longer be used.
If the provided responseObserver is an instance of ClientResponseObserver,
beforeStart() will be called.
ClientCallStreamObserverpublic static <ReqT,RespT> StreamObserver<ReqT> asyncBidiStreamingCall(io.grpc.ClientCall<ReqT,RespT> call, StreamObserver<RespT> responseObserver)
call should not be already started.
After calling this method, call should no longer be used.
If the provided responseObserver is an instance of ClientResponseObserver,
beforeStart() will be called.
ClientCallStreamObserverpublic static <ReqT,RespT> RespT blockingUnaryCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req)
call should not be already
started. After calling this method, call should no longer be used.io.grpc.StatusRuntimeException - on errorpublic static <ReqT,RespT> RespT blockingUnaryCall(io.grpc.Channel channel,
io.grpc.MethodDescriptor<ReqT,RespT> method,
io.grpc.CallOptions callOptions,
ReqT req)
call should not be already
started. After calling this method, call should no longer be used.io.grpc.StatusRuntimeException - on errorpublic static <ReqT,RespT> java.util.Iterator<RespT> blockingServerStreamingCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req)
Iterator over the
response stream. The call should not be already started. After calling this method,
call should no longer be used.
The returned iterator may throw StatusRuntimeException on error.
public static <ReqT,RespT> java.util.Iterator<RespT> blockingServerStreamingCall(io.grpc.Channel channel,
io.grpc.MethodDescriptor<ReqT,RespT> method,
io.grpc.CallOptions callOptions,
ReqT req)
Iterator over the
response stream. The call should not be already started. After calling this method,
call should no longer be used.
The returned iterator may throw StatusRuntimeException on error.
public static <ReqT,RespT> com.google.common.util.concurrent.ListenableFuture<RespT> futureUnaryCall(io.grpc.ClientCall<ReqT,RespT> call,
ReqT req)
ListenableFuture to the response. The
call should not be already started. After calling this method, call should no
longer be used.