open class MessageProducer<T : Any> : WriteStream<T>
Represents a stream of message that can be written to.
NOTE: This class has been automatically generated from the io.vertx.core.eventbus.MessageProducer non RX-ified interface using Vert.x codegen.
MessageProducer(delegate: MessageProducer<Any>)MessageProducer(delegate: MessageProducer<Any>, typeArg_0: TypeArg<T>) |
static val __TYPE_ARG: TypeArg<MessageProducer<Any>> |
|
val __typeArg_0: TypeArg<T> |
open fun address(): String |
|
open fun close(): Unit
Closes the producer, this method should be called when the message producer is not used anymore. |
|
open fun deliveryOptions(options: DeliveryOptions): MessageProducer<T>
Update the delivery options of this producer. |
|
open fun drainHandler(handler: Handler<Void>): MessageProducer<T> |
|
open fun end(t: T): Unit
Same as open fun end(): Unit
Closes the producer, calls |
|
open fun equals(other: Any?): Boolean |
|
open fun exceptionHandler(handler: Handler<Throwable>): MessageProducer<T> |
|
open fun getDelegate(): MessageProducer<Any> |
|
open fun hashCode(): Int |
|
open static fun <T : Any> newInstance(arg: MessageProducer<Any>): MessageProducer<T>open static fun <T : Any> newInstance(arg: MessageProducer<Any>, __typeArg_T: TypeArg<T>): MessageProducer<T> |
|
open fun send(message: T): MessageProducer<T>
Synonym for open fun <R : Any> send(message: T, replyHandler: Handler<AsyncResult<Message<R>>>): MessageProducer<T> |
|
open fun setWriteQueueMaxSize(maxSize: Int): MessageProducer<T> |
|
open fun toString(): String |
|
open fun write(data: T): MessageProducer<T> |
|
open fun writeQueueFull(): Boolean
This will return |