Uses of Class io.vertx.mutiny.core.eventbus.Message (SmallRye Mutiny - Client APIs 3.16.0 API)

Packages that use Message
Package Description

io.vertx.mutiny.core.eventbus

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

Fields in io.vertx.mutiny.core.eventbus with type parameters of type Message
Modifier and Type	Field	Description
`static TypeArg<Message>`	Message.`__TYPE_ARG`

Methods in io.vertx.mutiny.core.eventbus that return Message
Modifier and Type	Method	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)`
`<R> Message<R>`	Message.`replyAndRequestAndAwait(Object message)`	Blocking variant of `replyAndRequest(Object)`.
`<R> Message<R>`	Message.`replyAndRequestAndAwait(Object message, io.vertx.core.eventbus.DeliveryOptions options)`	Blocking variant of `replyAndRequest(Object,DeliveryOptions)`.
`<T> Message<T>`	EventBus.`requestAndAwait(String address, Object message)`	Blocking variant of `EventBus.request(String,Object)`.
`<T> Message<T>`	EventBus.`requestAndAwait(String address, Object message, io.vertx.core.eventbus.DeliveryOptions options)`	Blocking variant of `EventBus.request(String,Object,DeliveryOptions)`.

Methods in io.vertx.mutiny.core.eventbus that return types with arguments of type Message
Modifier and Type	Method	Description
`Pipe<Message<T>>`	MessageConsumer.`pipe()`
`<R> io.smallrye.mutiny.Uni<Message<R>>`	Message.`replyAndRequest(Object message)`	Reply to this message, specifying a `replyHandler` for the reply - i.e.
`<R> io.smallrye.mutiny.Uni<Message<R>>`	Message.`replyAndRequest(Object message, io.vertx.core.eventbus.DeliveryOptions options)`	Like `replyAndRequest(java.lang.Object)` but specifying `options` that can be used to configure the delivery.
`<T> io.smallrye.mutiny.Uni<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> io.smallrye.mutiny.Uni<Message<T>>`	EventBus.`request(String address, Object message, io.vertx.core.eventbus.DeliveryOptions options)`	Like `EventBus.request(java.lang.String, java.lang.Object)` but specifying `options` that can be used to configure the delivery.
`Iterable<Message<T>>`	MessageConsumer.`toBlockingIterable()`
`Stream<Message<T>>`	MessageConsumer.`toBlockingStream()`
`io.smallrye.mutiny.Multi<Message<T>>`	MessageConsumer.`toMulti()`

Method parameters in io.vertx.mutiny.core.eventbus with type arguments of type Message
Modifier and Type	Method	Description
`<T> MessageConsumer<T>`	EventBus.`consumer(String address, Consumer<Message<T>> handler)`
`MessageConsumer<T>`	MessageConsumer.`handler(Consumer<Message<T>> handler)`
`<T> MessageConsumer<T>`	EventBus.`localConsumer(String address, Consumer<Message<T>> handler)`
`io.smallrye.mutiny.Uni<Void>`	MessageConsumer.`pipeTo(WriteStream<Message<T>> dst)`	Pipe this `ReadStream` to the `WriteStream`.
`Void`	MessageConsumer.`pipeToAndAwait(WriteStream<Message<T>> dst)`	Blocking variant of `ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)`.
`void`	MessageConsumer.`pipeToAndForget(WriteStream<Message<T>> dst)`	Variant of `ReadStream.pipeTo(io.vertx.mutiny.core.streams.WriteStream)` that ignores the result of the operation.