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(Handler<Void> handler) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.endHandler(Handler<Void> handler) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.exceptionHandler(Handler<Throwable> handler) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.fail(Throwable t) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.fetch(long amount) |
GrpcBidiExchange<I,O> |
GrpcBidiExchange.handler(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) |