- limiter.onComplete(null, DataExistsReply.create(true));
- assertEquals("availablePermits", ++availablePermits, semaphore.availablePermits());
+ limiter.onComplete(null, new DataExistsReply(true, DataStoreVersions.CURRENT_VERSION));
+ assertEquals("availablePermits", ++availablePermits, limiter.availablePermits());