Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
test
@Test
public void testLoad() {
final AtomicInteger counter = new AtomicInteger();
int repetitions = 10000;
counter.set(repetitions);
for (int i = 0; i < repetitions; i++) {
redis.get("unknown", res -> {
if (res.failed()) {
fail(res.cause().getMessage());
return;
}
if (counter.decrementAndGet() == 0) {
testComplete();
}
});
}
await();
}
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.