Package | Description |
---|---|
io.vertx.grpc |
Modifier and Type | Method and Description |
---|---|
static <O,I> GrpcUniExchange<O,I> |
GrpcUniExchange.create(GrpcReadStream<I> read,
io.grpc.stub.StreamObserver<O> write) |
GrpcUniExchange<O,I> |
GrpcUniExchange.drainHandler(Handler<Void> handler) |
GrpcUniExchange<O,I> |
GrpcUniExchange.fail(Throwable t) |
GrpcUniExchange<O,I> |
GrpcUniExchange.handler(Handler<AsyncResult<I>> handler) |
GrpcUniExchange<O,I> |
GrpcUniExchange.setWriteQueueMaxSize(int maxSize) |
GrpcUniExchange<O,I> |
GrpcUniExchange.write(O data) |
Copyright © 2023 Eclipse. All rights reserved.