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