interface ReactiveWriteStream<T : Any> : WriteStream<T>, Publisher<T>
A Vert.x write stream that also implements reactive streams publisher interface.
Author
Tim Fox
static val DEFAULT_WRITE_QUEUE_MAX_SIZE: Int
Default write queue max size |
abstract fun close(): ReactiveWriteStream<T>
Close the stream |
|
abstract fun drainHandler(handler: Handler<Void>): ReactiveWriteStream<T> |
|
abstract fun end(): Unit
Calls |
|
abstract fun exceptionHandler(handler: Handler<Throwable>): ReactiveWriteStream<T> |
|
abstract fun setWriteQueueMaxSize(maxSize: Int): ReactiveWriteStream<T> |
|
abstract fun write(data: T): ReactiveWriteStream<T> |
|
open static fun <T : Any> writeStream(vertx: Vertx): ReactiveWriteStream<T>
Create a reactive write stream |