Beers2.java

    Router router = Router.router(vertx);
    router.route()
      .handler(ResponseContentTypeHandler.create())
      .handler(BodyHandler.create());
    router
      .get("/beer")
      .handler(beersHandlers::handleGetBeers);
    router
      .post("/beer")
      .handler(beersHandlers::handlePostBeer);

public void handleGetBeers(RoutingContext rc) {
    beersCircuitBreaker
      .execute(
        () -> beersServiceClient
          .rxGetBeersList()
          .flatMap(res -> res.statusCode() != 200 ? Single.error(new HttpStatusException(500, "Beers service error")) : Single.just(res))
      )
      .onErrorResumeNext(t -> Single.error(new HttpStatusException(503, "Beers service not available", t)))
      .flatMapObservable(httpResponse -> Observable.fromIterable(httpResponse.bodyAsJsonArray()))
      .map(o -> new io.slinkydeveloper.brewery.beers.client.models.Beer((JsonObject) o))
      .flatMapSingle(this::solveStyleAndBuildApiBeer)
      .collectInto(new JsonArray(), (j, apiBeer) -> j.add(apiBeer.toJson()))
      .map(JsonArray::encode)
      .subscribe(rc.response()::end, rc::fail);
  }

  public void handlePostBeer(RoutingContext rc) {
    JsonObject body = rc.getBodyAsJson();
    ((body.containsKey("style")) ? addBeerAndStyle(body) : addBeer(body))
      .map(result -> result.toJson().encode())
      .subscribe(rc.response()::end, rc::fail);
  }