refactoring

pull/2009/head
Nikita Koksharov 6 years ago
parent 5c2b4804bb
commit 14a2582e75

@ -52,7 +52,7 @@ public class RedissonBlockingDequeReactiveTest extends BaseReactiveTest {
RBlockingDequeReactive<String> blockingDeque = redisson.getBlockingDeque("blocking_deque");
long start = System.currentTimeMillis();
String redisTask = sync(blockingDeque.pollLastAndOfferFirstTo("deque", 1, TimeUnit.SECONDS));
assertThat(System.currentTimeMillis() - start).isBetween(950L, 1100L);
assertThat(System.currentTimeMillis() - start).isBetween(950L, 1150L);
assertThat(redisTask).isNull();
}

Loading…
Cancel
Save