Uses of Class
io.vertx.reactivex.core.eventbus.Message

Packages that use Message

Package	Description
io.vertx.reactivex.core.eventbus

Uses of Message in io.vertx.reactivex.core.eventbus

Classes in io.vertx.reactivex.core.eventbus that implement interfaces with type arguments of type Message

Modifier and Type	Class	Description
class	MessageConsumer<T>	An event bus consumer object representing a stream of message to an EventBus address that can be read from.

Fields in io.vertx.reactivex.core.eventbus with type parameters of type Message

Modifier and Type	Field	Description
static final io.vertx.lang.rx.TypeArg<Message>	Message.__TYPE_ARG

Methods in io.vertx.reactivex.core.eventbus that return Message

Modifier and Type	Method	Description
Message<T>	DeliveryContext.message()
static <T> Message<T>	Message.newInstance(Message arg)
static <T> Message<T>	Message.newInstance(Message arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

Methods in io.vertx.reactivex.core.eventbus that return types with arguments of type Message

Modifier and Type	Method	Description
Pipe<Message<T>>	MessageConsumer.pipe()	Pause this stream and return a to transfer the elements of this stream to a destination .
<R> Future<Message<R>>	Message.replyAndRequest(Object message)	Reply to this message, specifying a replyHandler for the reply - i.e. to receive the reply to the reply.
<R> Future<Message<R>>	Message.replyAndRequest(Object message, DeliveryOptions options)	Like Message.replyAndRequest(Object) but specifying options that can be used to configure the delivery.
<T> Future<Message<T>>	EventBus.request(String address, Object message)	Sends a message and specify a replyHandler that will be called if the recipient subsequently replies to the message.
<T> Future<Message<T>>	EventBus.request(String address, Object message, DeliveryOptions options)	Like EventBus.request(String, Object) but specifying options that can be used to configure the delivery.
<R> Single<Message<R>>	Message.rxReplyAndRequest(Object message)	Reply to this message, specifying a replyHandler for the reply - i.e. to receive the reply to the reply.
<R> Single<Message<R>>	Message.rxReplyAndRequest(Object message, DeliveryOptions options)	Like Message.replyAndRequest(Object) but specifying options that can be used to configure the delivery.
<T> Single<Message<T>>	EventBus.rxRequest(String address, Object message)	Sends a message and specify a replyHandler that will be called if the recipient subsequently replies to the message.
<T> Single<Message<T>>	EventBus.rxRequest(String address, Object message, DeliveryOptions options)	Like EventBus.request(String, Object) but specifying options that can be used to configure the delivery.
Flowable<Message<T>>	MessageConsumer.toFlowable()
Observable<Message<T>>	MessageConsumer.toObservable()

Method parameters in io.vertx.reactivex.core.eventbus with type arguments of type Message

Modifier and Type	Method	Description
<T> MessageConsumer<T>	EventBus.consumer(MessageConsumerOptions options, Handler<Message<T>> handler)	Create a consumer and register it against the specified options address.
<T> MessageConsumer<T>	EventBus.consumer(String address, Handler<Message<T>> handler)	Create a consumer and register it against the specified address.
MessageConsumer<T>	MessageConsumer.handler(Handler<Message<T>> handler)
<T> MessageConsumer<T>	EventBus.localConsumer(String address, Handler<Message<T>> handler)	Like EventBus.consumer(MessageConsumerOptions) but the address won't be propagated across the cluster.
Future<Void>	MessageConsumer.pipeTo(WriteStream<Message<T>> dst)	Pipe this ReadStream to the WriteStream.
Completable	MessageConsumer.rxPipeTo(WriteStream<Message<T>> dst)	Pipe this ReadStream to the WriteStream.