Skip to content

Instantly share code, notes, and snippets.

@msavy msavy/gist:8f72fbaca9be0866c73d Secret
Created Aug 13, 2015

Embed
What would you like to do?
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() { ... }
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.