TICK
Thread.sleep(TICK);
} while (aggregate.asMap().isEmpty() && n++ < (1000 / TICK));
Thread.sleep(TICK * EXPECTED_TICKS);
consumer.setOption(Option.aggrate, Option.millis(TICK));
consumer.setOption(Option.aggrate, Option.millis(TICK));
Thread.sleep(TICK);
Thread.sleep(TICK);
static final int TICK = 50;
Thread.sleep(TICK);
} while (aggregate.asMap().isEmpty() && n++ < (1000 / TICK));