public final class ClientCalls
extends java.lang.Object
Modifier and Type | Method | 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.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.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.public 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.public 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.public 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.public 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.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.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.