Package | Description |
---|---|
io.vertx.rxjava.grpc.client |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<GrpcClientResponse> |
GrpcClientResponse.__TYPE_ARG |
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) |
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) |
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.pause() |
GrpcClientResponse<Req,Resp> |
GrpcClientResponse.resume() |
Modifier and Type | Method and Description |
---|---|
Future<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.response() |
Single<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.rxResponse() |
Single<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.rxSend(Observable<Req> body) |
Single<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.rxSend(ReadStream<Req> body) |
Single<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.rxSend(Req item) |
Future<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.send(Observable<Req> body) |
Future<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.send(ReadStream<Req> body) |
Future<GrpcClientResponse<Req,Resp>> |
GrpcClientRequest.send(Req item) |
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.