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.