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