vertx / io.vertx.ext.reactivestreams / ReactiveWriteStream

# ReactiveWriteStream

`interface ReactiveWriteStream<T : Any> : WriteStream<T>, Publisher<T>`

A Vert.x write stream that also implements reactive streams publisher interface.

Author
Tim Fox

### Properties

DEFAULT_WRITE_QUEUE_MAX_SIZE | `static val DEFAULT_WRITE_QUEUE_MAX_SIZE: Int` Default write queue max size

### Functions

close | `abstract fun close(): ReactiveWriteStream<T>` Close the stream
drainHandler | `abstract fun drainHandler(handler: Handler<Void>): ReactiveWriteStream<T>`
end | `abstract fun end(): Unit` Calls `#close()`.
exceptionHandler | `abstract fun exceptionHandler(handler: Handler<Throwable>): ReactiveWriteStream<T>`
setWriteQueueMaxSize | `abstract fun setWriteQueueMaxSize(maxSize: Int): ReactiveWriteStream<T>`
write | `abstract fun write(data: T): ReactiveWriteStream<T>`
writeStream | `open static fun <T : Any> writeStream(vertx: Vertx): ReactiveWriteStream<T>` Create a reactive write stream