Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<MessageProducer> |
__TYPE_ARG |
io.vertx.lang.rx.TypeArg<T> |
__typeArg_0 |
Constructor and Description |
---|
MessageProducer(MessageProducer delegate) |
MessageProducer(Object delegate,
io.vertx.lang.rx.TypeArg<T> typeArg_0) |
Modifier and Type | Method and Description |
---|---|
String |
address() |
Completable |
close()
Same as
close() but with an handler called when the operation completes |
MessageProducer<T> |
deliveryOptions(DeliveryOptions options)
Update the delivery options of this producer.
|
boolean |
equals(Object o) |
MessageProducer |
getDelegate() |
int |
hashCode() |
static <T> MessageProducer<T> |
newInstance(MessageProducer arg) |
static <T> MessageProducer<T> |
newInstance(MessageProducer arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
Completable |
rxClose()
Same as
close() but with an handler called when the operation completes |
Completable |
rxWrite(T body)
Write a message to the event-bus, either sending or publishing.
|
String |
toString() |
Completable |
write(T body)
Write a message to the event-bus, either sending or publishing.
|
public static final io.vertx.lang.rx.TypeArg<MessageProducer> __TYPE_ARG
public final io.vertx.lang.rx.TypeArg<T> __typeArg_0
public MessageProducer(MessageProducer delegate)
public MessageProducer getDelegate()
public MessageProducer<T> deliveryOptions(DeliveryOptions options)
options
- the new optionspublic String address()
public Completable write(T body)
body
- the message bodypublic Completable rxWrite(T body)
body
- the message bodypublic Completable close()
close()
but with an handler
called when the operation completespublic Completable rxClose()
close()
but with an handler
called when the operation completespublic static <T> MessageProducer<T> newInstance(MessageProducer arg)
public static <T> MessageProducer<T> newInstance(MessageProducer arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)
Copyright © 2021 Eclipse. All rights reserved.