limiter.acquire(permits);
int availablePermits = 0;
- limiter.onComplete(null, DataExistsReply.create(true));
+ limiter.onComplete(null, new DataExistsReply(true, DataStoreVersions.CURRENT_VERSION));
assertEquals("availablePermits", ++availablePermits, limiter.availablePermits());
- limiter.onComplete(null, DataExistsReply.create(true));
+ limiter.onComplete(null, new DataExistsReply(true, DataStoreVersions.CURRENT_VERSION));
assertEquals("availablePermits", ++availablePermits, limiter.availablePermits());
limiter.onComplete(null, new IllegalArgumentException());