public class GrpcWriteStream<T> extends Object implements io.vertx.core.streams.WriteStream<T>
Constructor and Description |
---|
GrpcWriteStream(io.grpc.stub.StreamObserver<T> observer) |
Modifier and Type | Method and Description |
---|---|
io.vertx.core.streams.WriteStream<T> |
drainHandler(io.vertx.core.Handler<Void> hndlr) |
void |
end(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> hndlr) |
io.vertx.core.streams.WriteStream<T> |
exceptionHandler(io.vertx.core.Handler<Throwable> hndlr) |
io.vertx.core.streams.WriteStream<T> |
setWriteQueueMaxSize(int i) |
io.grpc.stub.StreamObserver<T> |
streamObserver()
Low level control of the observer for advanced use cases.
|
io.vertx.core.Future<Void> |
write(T data) |
void |
write(T data,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> hndlr) |
boolean |
writeQueueFull() |
public GrpcWriteStream(io.grpc.stub.StreamObserver<T> observer)
public io.vertx.core.streams.WriteStream<T> exceptionHandler(io.vertx.core.Handler<Throwable> hndlr)
exceptionHandler
in interface io.vertx.core.streams.StreamBase
exceptionHandler
in interface io.vertx.core.streams.WriteStream<T>
public io.vertx.core.Future<Void> write(T data)
write
in interface io.vertx.core.streams.WriteStream<T>
public void write(T data, io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> hndlr)
write
in interface io.vertx.core.streams.WriteStream<T>
public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> hndlr)
end
in interface io.vertx.core.streams.WriteStream<T>
public io.vertx.core.streams.WriteStream<T> setWriteQueueMaxSize(int i)
setWriteQueueMaxSize
in interface io.vertx.core.streams.WriteStream<T>
public boolean writeQueueFull()
writeQueueFull
in interface io.vertx.core.streams.WriteStream<T>
public io.vertx.core.streams.WriteStream<T> drainHandler(io.vertx.core.Handler<Void> hndlr)
drainHandler
in interface io.vertx.core.streams.WriteStream<T>
public io.grpc.stub.StreamObserver<T> streamObserver()
Copyright © 2020 Eclipse. All rights reserved.