Package | Description |
---|---|
io.vertx.grpc.client | |
io.vertx.reactivex.grpc.client | |
io.vertx.rxjava.grpc.client | |
io.vertx.rxjava3.grpc.client |
Modifier and Type | Method and Description |
---|---|
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.endHandler(Handler<Void> handler) |
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.errorHandler(Handler<GrpcError> handler) |
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.exceptionHandler(Handler<Throwable> handler) |
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.fetch(long amount) |
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.handler(Handler<Resp> handler) |
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.messageHandler(Handler<GrpcMessage> handler) |
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.pause() |
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.resume() |
Modifier and Type | Method and Description |
---|---|
Future<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.response() |
default Future<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.send(ReadStream<Req> body) |
default Future<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.send(Req item) |
Modifier and Type | Method and Description |
---|---|
default <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 . |
Modifier and Type | Method and Description |
---|---|
GrpcClientResponse |
GrpcClientResponse.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static <Req,Resp> GrpcClientResponse<Req,Resp> |
GrpcClientResponse.newInstance(GrpcClientResponse arg) |
static <Req,Resp> GrpcClientResponse<Req,Resp> |
GrpcClientResponse.newInstance(GrpcClientResponse arg,
io.vertx.lang.rx.TypeArg<Req> __typeArg_Req,
io.vertx.lang.rx.TypeArg<Resp> __typeArg_Resp) |
Constructor and Description |
---|
GrpcClientResponse(GrpcClientResponse delegate) |
Modifier and Type | Method and Description |
---|---|
GrpcClientResponse |
GrpcClientResponse.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static <Req,Resp> GrpcClientResponse<Req,Resp> |
GrpcClientResponse.newInstance(GrpcClientResponse arg) |
static <Req,Resp> GrpcClientResponse<Req,Resp> |
GrpcClientResponse.newInstance(GrpcClientResponse arg,
io.vertx.lang.rx.TypeArg<Req> __typeArg_Req,
io.vertx.lang.rx.TypeArg<Resp> __typeArg_Resp) |
Constructor and Description |
---|
GrpcClientResponse(GrpcClientResponse delegate) |
Modifier and Type | Method and Description |
---|---|
GrpcClientResponse |
GrpcClientResponse.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static <Req,Resp> GrpcClientResponse<Req,Resp> |
GrpcClientResponse.newInstance(GrpcClientResponse arg) |
static <Req,Resp> GrpcClientResponse<Req,Resp> |
GrpcClientResponse.newInstance(GrpcClientResponse arg,
io.vertx.lang.rx.TypeArg<Req> __typeArg_Req,
io.vertx.lang.rx.TypeArg<Resp> __typeArg_Resp) |
Constructor and Description |
---|
GrpcClientResponse(GrpcClientResponse delegate) |
Copyright © 2023 Eclipse. All rights reserved.