Package | Description |
---|---|
io.vertx.rxjava.core.eventbus |
Modifier and Type | Field and Description |
---|---|
static TypeArg<Message> |
Message.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
Message<T> |
DeliveryContext.message() |
static <T> Message<T> |
Message.newInstance(io.vertx.core.eventbus.Message arg) |
static <T> Message<T> |
Message.newInstance(io.vertx.core.eventbus.Message arg,
TypeArg<T> __typeArg_T) |
Modifier and Type | Method and Description |
---|---|
Pipe<Message<T>> |
MessageConsumer.pipe()
Pause this stream and return a to transfer the elements of this stream to a destination .
|
<R> rx.Observable<Message<R>> |
Message.replyAndRequestObservable(Object message)
Deprecated.
use
rxReplyAndRequest(java.lang.Object) instead |
<R> rx.Observable<Message<R>> |
Message.replyAndRequestObservable(Object message,
io.vertx.core.eventbus.DeliveryOptions options)
Deprecated.
use
rxReplyAndRequest(java.lang.Object) instead |
<R> rx.Observable<Message<R>> |
Message.replyObservable(Object message)
Deprecated.
use
rxReply(java.lang.Object) instead |
<R> rx.Observable<Message<R>> |
Message.replyObservable(Object message,
io.vertx.core.eventbus.DeliveryOptions options)
Deprecated.
use
rxReply(java.lang.Object) instead |
<T> rx.Observable<Message<T>> |
EventBus.requestObservable(String address,
Object message)
Deprecated.
|
<T> rx.Observable<Message<T>> |
EventBus.requestObservable(String address,
Object message,
io.vertx.core.eventbus.DeliveryOptions options)
Deprecated.
|
<R> rx.Single<Message<R>> |
Message.rxReply(Object message)
Deprecated.
|
<R> rx.Single<Message<R>> |
Message.rxReply(Object message,
io.vertx.core.eventbus.DeliveryOptions options)
Deprecated.
|
<R> rx.Single<Message<R>> |
Message.rxReplyAndRequest(Object message)
Reply to this message, specifying a
replyHandler for the reply - i.e. |
<R> rx.Single<Message<R>> |
Message.rxReplyAndRequest(Object message,
io.vertx.core.eventbus.DeliveryOptions options)
Like
replyAndRequest(java.lang.Object, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.eventbus.Message<R>>>) but specifying options that can be used
to configure the delivery. |
<T> rx.Single<Message<T>> |
EventBus.rxRequest(String address,
Object message)
Sends a message and and specify a
replyHandler that will be called if the recipient
subsequently replies to the message. |
<T> rx.Single<Message<T>> |
EventBus.rxRequest(String address,
Object message,
io.vertx.core.eventbus.DeliveryOptions options)
Like
EventBus.request(java.lang.String, java.lang.Object, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.eventbus.Message<T>>>) but specifying options that can be used to configure the delivery. |
<T> rx.Single<Message<T>> |
EventBus.rxSend(String address,
Object message)
Deprecated.
|
<T> rx.Single<Message<T>> |
EventBus.rxSend(String address,
Object message,
io.vertx.core.eventbus.DeliveryOptions options)
Deprecated.
|
<T> rx.Observable<Message<T>> |
EventBus.sendObservable(String address,
Object message)
Deprecated.
|
<T> rx.Observable<Message<T>> |
EventBus.sendObservable(String address,
Object message,
io.vertx.core.eventbus.DeliveryOptions options)
Deprecated.
|
rx.Observable<Message<T>> |
MessageConsumer.toObservable() |
Modifier and Type | Method and Description |
---|---|
<T> MessageConsumer<T> |
EventBus.consumer(String address,
io.vertx.core.Handler<Message<T>> handler)
Create a consumer and register it against the specified address.
|
MessageConsumer<T> |
MessageConsumer.handler(io.vertx.core.Handler<Message<T>> handler) |
<T> MessageConsumer<T> |
EventBus.localConsumer(String address,
io.vertx.core.Handler<Message<T>> handler)
Like
EventBus.consumer(java.lang.String) but the address won't be propagated across the cluster. |
void |
MessageConsumer.pipeTo(WriteStream<Message<T>> dst)
Like
ReadStream.pipeTo(io.vertx.rxjava.core.streams.WriteStream<T>) but with no completion handler. |
void |
MessageConsumer.pipeTo(WriteStream<Message<T>> dst,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream . |
rx.Observable<Void> |
MessageConsumer.pipeToObservable(WriteStream<Message<T>> dst)
|
<R> void |
Message.reply(Object message,
io.vertx.core.eventbus.DeliveryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<R>>> replyHandler)
Deprecated.
|
<R> void |
Message.reply(Object message,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<R>>> replyHandler)
Deprecated.
|
<R> void |
Message.replyAndRequest(Object message,
io.vertx.core.eventbus.DeliveryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<R>>> replyHandler)
Like
replyAndRequest(java.lang.Object, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.eventbus.Message<R>>>) but specifying options that can be used
to configure the delivery. |
<R> void |
Message.replyAndRequest(Object message,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<R>>> replyHandler)
Reply to this message, specifying a
replyHandler for the reply - i.e. |
<T> EventBus |
EventBus.request(String address,
Object message,
io.vertx.core.eventbus.DeliveryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<T>>> replyHandler)
Like
EventBus.request(java.lang.String, java.lang.Object, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.eventbus.Message<T>>>) but specifying options that can be used to configure the delivery. |
<T> EventBus |
EventBus.request(String address,
Object message,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<T>>> replyHandler)
Sends a message and and specify a
replyHandler that will be called if the recipient
subsequently replies to the message. |
rx.Single<Void> |
MessageConsumer.rxPipeTo(WriteStream<Message<T>> dst)
Pipe this
ReadStream to the WriteStream . |
<T> EventBus |
EventBus.send(String address,
Object message,
io.vertx.core.eventbus.DeliveryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<T>>> replyHandler)
Deprecated.
|
<T> EventBus |
EventBus.send(String address,
Object message,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<T>>> replyHandler)
Deprecated.
|
<R> MessageProducer<T> |
MessageProducer.send(T message,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Message<R>>> replyHandler)
Deprecated.
|
Copyright © 2019 Eclipse. All rights reserved.