| Package | Description | 
|---|---|
| io.vertx.grpc | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
GrpcBidiExchange<I,O>  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> GrpcReadStream<T> | 
GrpcReadStream.create()  | 
static <T> GrpcReadStream<T> | 
GrpcReadStream.create(io.grpc.stub.StreamObserver<T> observer)  | 
GrpcReadStream<T> | 
GrpcReadStream.endHandler(Handler<Void> endHandler)
Set an end handler. 
 | 
GrpcReadStream<T> | 
GrpcReadStream.exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream. 
 | 
GrpcReadStream<T> | 
GrpcReadStream.fetch(long amount)
Fetch the specified  
amount of elements. | 
GrpcReadStream<T> | 
GrpcReadStream.handler(Handler<T> handler)
Set a data handler. 
 | 
GrpcReadStream<T> | 
GrpcReadStream.pause()
Pause the  
ReadSupport. | 
GrpcReadStream<T> | 
GrpcReadStream.resume()
Resume reading. 
 | 
GrpcReadStream<T> | 
GrpcReadStream.setReadObserver(io.grpc.stub.StreamObserver<T> observer)  | 
| Modifier and Type | Method and Description | 
|---|---|
static <I,O> GrpcBidiExchange<I,O> | 
GrpcBidiExchange.create(GrpcReadStream<I> readStream,
      io.grpc.stub.StreamObserver<O> writeObserver)  | 
static <O,I> GrpcUniExchange<O,I> | 
GrpcUniExchange.create(GrpcReadStream<I> read,
      io.grpc.stub.StreamObserver<O> write)  | 
Copyright © 2020 Eclipse. All rights reserved.