Package | Description |
---|---|
io.vertx.rxjava.grpc.client |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<GrpcClientRequest> |
GrpcClientRequest.__TYPE_ARG |
Modifier and Type | Method and 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.fullMethodName(String fullMethodName)
Set the full method name to call, it must follow the format
package-name + '.' + service-name + '/' + method-name
or an IllegalArgumentException is thrown. |
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) |
Modifier and Type | Method and Description |
---|---|
Future<GrpcClientRequest<Buffer,Buffer>> |
GrpcClient.request(SocketAddress server)
Connect to the remote
server and create a request for any hosted gRPC service. |
<Req,Resp> Future<GrpcClientRequest<Req,Resp>> |
GrpcClient.request(SocketAddress server,
io.grpc.MethodDescriptor<Req,Resp> service)
Connect to the remote
server and create a request for given method of a hosted gRPC service. |
Single<GrpcClientRequest<Buffer,Buffer>> |
GrpcClient.rxRequest(SocketAddress server)
Connect to the remote
server and create a request for any hosted gRPC service. |
<Req,Resp> Single<GrpcClientRequest<Req,Resp>> |
GrpcClient.rxRequest(SocketAddress server,
io.grpc.MethodDescriptor<Req,Resp> service)
Connect to the remote
server and create a request for given method of a hosted gRPC service. |
Modifier and Type | Method and Description |
---|---|
<Req,Resp,T> |
GrpcClient.call(SocketAddress server,
io.grpc.MethodDescriptor<Req,Resp> service,
Handler<GrpcClientRequest<Req,Resp>> requestHandler,
java.util.function.Function<GrpcClientResponse<Req,Resp>,Future<T>> resultFn)
Call the
service gRPC service hosted by server . |
<Req,Resp,T> |
GrpcClient.rxCall(SocketAddress server,
io.grpc.MethodDescriptor<Req,Resp> service,
Handler<GrpcClientRequest<Req,Resp>> requestHandler,
java.util.function.Function<GrpcClientResponse<Req,Resp>,Future<T>> resultFn)
Call the
service gRPC service hosted by server . |
Copyright © 2023 Eclipse. All rights reserved.