| Package | Description | 
|---|---|
| io.vertx.grpc | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
GrpcBidiExchange<I,O>  | 
interface  | 
GrpcUniExchange<O,I>  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> GrpcWriteStream<T> | 
GrpcWriteStream.create(io.grpc.stub.StreamObserver<T> observer)  | 
GrpcWriteStream<T> | 
GrpcWriteStream.drainHandler(Handler<Void> handler)
Set a drain handler on the stream. 
 | 
GrpcWriteStream<T> | 
GrpcWriteStream.exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the write stream. 
 | 
GrpcWriteStream<T> | 
GrpcWriteStream.fail(Throwable t)
Send an error event into the stream. 
 | 
GrpcWriteStream<T> | 
GrpcWriteStream.setWriteQueueMaxSize(int maxSize)
Set the maximum size of the write queue to  
maxSize. | 
GrpcWriteStream<T> | 
GrpcWriteStream.write(T data)
Write some data to the stream. 
 | 
Copyright © 2023 Eclipse. All rights reserved.