Modifier and Type | Method and Description |
---|---|
static <I,O> GrpcBidiExchange<I,O> |
GrpcBidiExchange.create(GrpcReadStream<I> readStream,
io.grpc.stub.StreamObserver<O> writeObserver) |
static <I,O> GrpcBidiExchange<I,O> |
GrpcBidiExchange.create(io.grpc.stub.StreamObserver<I> readObserver,
io.grpc.stub.StreamObserver<O> writeObserver) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.drainHandler(io.vertx.core.Handler<Void> handler) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.endHandler(io.vertx.core.Handler<Void> handler) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.fail(Throwable t) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.handler(io.vertx.core.Handler<I> handler) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.pause() |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.resume() |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.setReadObserver(io.grpc.stub.StreamObserver<I> observer) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.setWriteQueueMaxSize(int maxSize) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.write(O data) |
Copyright © 2017. All rights reserved.