test

gistfile1.java

  @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();
  }