| 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) |