Package | Description |
---|---|
io.vertx.ext.reactivestreams |
Modifier and Type | Method and Description |
---|---|
ReactiveWriteStream<T> |
ReactiveWriteStream.close()
Close the stream
|
ReactiveWriteStream<T> |
ReactiveWriteStream.drainHandler(Handler<Void> handler) |
ReactiveWriteStream<T> |
ReactiveWriteStream.exceptionHandler(Handler<Throwable> handler) |
ReactiveWriteStream<T> |
ReactiveWriteStream.setWriteQueueMaxSize(int maxSize) |
static <T> ReactiveWriteStream<T> |
ReactiveWriteStream.writeStream(Vertx vertx)
Create a reactive write stream
|
Copyright © 2022 Eclipse. All rights reserved.