router.get("/api/v1/mypostcall").handler(routingContext -> { // I have existing asyncjsonCompletable = ...
// How do I respond using the CompletionStage (or CompletableFuture) to VertX
我正在尝试将twitter4j与vertx事件循环集成在一起,我不知道我这样做是否正确。虽然我是一个Node.js开发人员,但我对vertx还是新手,所以我熟悉事件循环/单线程概念。在我的测试中,我想订阅twitter流并在vertx事件总线上发布该流。我已经创建了一个不可知论的TwitterAPI类,它将把twitter流转换为一个可观察的流(稍后将链接到vertx ): public Observable以下是修改后的代码:
public class