Emitter - Errors Sending Messages

[josephearl]

The docs give this example of using an Emitter in imperative code:

public void send(double d) {
  emitter.send(d);
}

Should this not be something more like:

public void send(double d) throws ExecutionException, InterruptedException {
  emitter.send(d).toCompletableFuture().get();
}

So that if the message fails to send an exception (in this case wrapped in an ExecutionException) is thrown from the imperative code?

However this does have the side-effect of slowing down sending messages from imperative code - the method only returns once the message is sent.

[josephearl]

Actually I must have been blind, can see this is now mentioned https://smallrye.io/smallrye-reactive-messaging/4.9.0/concepts/emitter/#emitter-and-channel

[josephearl]

Re-opening: How would you do the same when sending a Message? (the emitter send returns the message rather than a completion stage)