gistfile1.txt

private BlockingMetricsPushingThing blockingMetricsPusher = ...;
private Vertx vertx;

void collectData(Metrics frequentData) {
  vertx.executeBlocking(future -> { 
      blockingMetricsPusher.push(frequentData); // e.g. this might happen once per request-response cycle in an HTTP client. So very high volume.
  }, this::resultHandler)
  blockingMetricsThing
}

void resultHandler() { ... }