Uses of Class
io.vertx.reactivex.grpc.client.GrpcClientRequest
-
Packages that use GrpcClientRequest Package Description io.vertx.reactivex.grpc.client -
-
Uses of GrpcClientRequest in io.vertx.reactivex.grpc.client
Fields in io.vertx.reactivex.grpc.client with type parameters of type GrpcClientRequest Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<GrpcClientRequest>
GrpcClientRequest. __TYPE_ARG
Methods in io.vertx.reactivex.grpc.client that return GrpcClientRequest Modifier and Type Method Description GrpcClientRequest<Req,Resp>
GrpcClientRequest. drainHandler(Handler<Void> handler)
GrpcClientRequest<Req,Resp>
GrpcClientRequest. encoding(String encoding)
GrpcClientRequest<Req,Resp>
GrpcClientRequest. exceptionHandler(Handler<Throwable> handler)
GrpcClientRequest<Req,Resp>
GrpcClientRequest. format(WireFormat format)
GrpcClientRequest<Req,Resp>
GrpcClientRequest. fullMethodName(String fullMethodName)
Set the full method name to call, it must follow the formatpackage-name + '.' + service-name + '/' + method-name
or anIllegalArgumentException
is thrown.GrpcClientRequest<Req,Resp>
GrpcClientRequest. idleTimeout(long timeout)
Sets the amount of time after which, if the request does not return any data within the timeout period, the request/response is cancelled and the related futures.GrpcClientRequest<Req,Resp>
GrpcClientRequest. methodName(String methodName)
Set the method name to call.static <Req,Resp>
GrpcClientRequest<Req,Resp>GrpcClientRequest. newInstance(GrpcClientRequest arg)
static <Req,Resp>
GrpcClientRequest<Req,Resp>GrpcClientRequest. newInstance(GrpcClientRequest arg, io.vertx.lang.rx.TypeArg<Req> __typeArg_Req, io.vertx.lang.rx.TypeArg<Resp> __typeArg_Resp)
GrpcClientRequest<Req,Resp>
GrpcClientRequest. serviceName(ServiceName serviceName)
Set the service name to call.GrpcClientRequest<Req,Resp>
GrpcClientRequest. setWriteQueueMaxSize(int maxSize)
GrpcClientRequest<Req,Resp>
GrpcClientRequest. timeout(long timeout, TimeUnit unit)
Set agrpc-timeout
header to be sent to the server to indicate the client expects a response with a timeout.Methods in io.vertx.reactivex.grpc.client that return types with arguments of type GrpcClientRequest Modifier and Type Method Description Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Future<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. request(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service.<Req,Resp>
Future<GrpcClientRequest<Req,Resp>>GrpcClient. request(Address server, ServiceMethod<Resp,Req> method)
Connect to the remoteserver
and create a request for any hosted gRPC service.<Req,Resp>
Future<GrpcClientRequest<Req,Resp>>GrpcClient. request(ServiceMethod<Resp,Req> method)
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest()
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.Single<GrpcClientRequest<Buffer,Buffer>>
GrpcClient. rxRequest(Address server)
Connect to the remoteserver
and create a request for any hosted gRPC service.<Req,Resp>
Single<GrpcClientRequest<Req,Resp>>GrpcClient. rxRequest(Address server, ServiceMethod<Resp,Req> method)
Connect to the remoteserver
and create a request for any hosted gRPC service.<Req,Resp>
Single<GrpcClientRequest<Req,Resp>>GrpcClient. rxRequest(ServiceMethod<Resp,Req> method)
LikeGrpcClient.request(io.vertx.core.net.Address)
with the default remote server.
-