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(io.vertx.core.Handler<Void> handler) |
GrpcUniExchange<O,I> |
GrpcUniExchange.fail(Throwable t) |
GrpcUniExchange<O,I> |
GrpcUniExchange.handler(io.vertx.core.Handler<io.vertx.core.AsyncResult<I>> handler) |
GrpcUniExchange<O,I> |
GrpcUniExchange.setWriteQueueMaxSize(int maxSize) |
GrpcUniExchange<O,I> |
GrpcUniExchange.write(O data) |
Copyright © 2018. All rights reserved.