Added Promises and simplified streaming to Vert.x. Check out the Reakt Vertx Website.
final Promise<Employee> promise = Promises.<Employee>promise();
promise.thenExpect(this::handleResult).catchError(this::handleError);
/** Convert the Reakt promise to a Vert.x asyncResultHandler */
final Handler<AsyncResult<Employee>> asyncResultHandler = ReaktVertx.convertPromise(promise);You can also use replay promises, all promises, any promises, and other features of Reakt to simplify async, reactive Vertx/Java development.
You can see a Vert.x event bus example in the wiki. If you are new to Reakt, stop by Reakt Website and the Reakt Wiki to learn more about Reakt promises.
<dependency>
<groupId>io.advantageous.reakt</groupId>
<artifactId>reakt-vertx</artifactId>
<version>2.1.0.RELEASE</version>
</dependency>compile 'io.advantageous.reakt:reakt-vertx:2.1.0.RELEASE'