--
You received this message because you are subscribed to the Google Groups "vert.x" group.
To unsubscribe from this group and stop receiving emails from it, send an email to vertx+un...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
On 14 Mar 2015 at 14:26:03, Erwin de Gier (er...@edegier.nl) wrote:
Thank you, I merged the request, the Unit test is a good addition. Is there any specific example with the RxJava api that you want to see in the archetype?
List<Promise<Message<JsonObject>>> promises = new ArrayList<>();
promises.add(whenEventBus.<JsonObject>send("et.vertx.eb.1", new JsonObject().putString("message", "hello")));
promises.add(whenEventBus.<JsonObject>send("et.vertx.eb.2", new JsonObject().putString("message", "world")));
when.all(promises).then(
replies -> {
// On success
return null;
},
t -> {
// On fail
return null;
});