stream-iori

//假设你是做多次eb通信, 而且address2必须依赖address1的结果. 

CompletableFuture<String> future = new CompletableFuture<>();
vertx.eventBus().send("address1", "a", (Message<String> event) -> {
    future.complete(event.body()); //把address1返回的值放入future
});
vertx.eventBus().send("address2", "b", (Message<String> event) -> {
   //这里s 是刚才上面address1返回的值,这里累加起来
   future.thenCompose(s -> CompletableFuture.completedFuture(s + event.body())); 
});