vertx / io.vertx.rxjava.core.eventbus / EventBus / rxSend

rxSend

open fun <T : Any> rxSend(address: String, message: Any): Single<Message<T>>

Like io.vertx.rxjava.core.eventbus.EventBus#send but specifying a replyHandler that will be called if the recipient subsequently replies to the message.

Parameters

address - the address to send it to

message - the message, may be null

Return

open fun <T : Any> rxSend(address: String, message: Any, options: DeliveryOptions): Single<Message<T>>

Like io.vertx.rxjava.core.eventbus.EventBus#send but specifying a replyHandler that will be called if the recipient subsequently replies to the message.

Parameters

address - the address to send it to

message - the message, may be null

options - delivery options

Return