|
15 | 15 | */ |
16 | 16 | package org.springframework.data.redis.cache; |
17 | 17 |
|
18 | | -import static org.assertj.core.api.Assertions.assertThat; |
19 | | -import static org.assertj.core.api.Assumptions.assumeThat; |
20 | | -import static org.springframework.data.redis.cache.RedisCacheWriter.RedisCacheWriterConfigurer; |
21 | | -import static org.springframework.data.redis.cache.RedisCacheWriter.TtlFunction; |
22 | | -import static org.springframework.data.redis.cache.RedisCacheWriter.lockingRedisCacheWriter; |
23 | | -import static org.springframework.data.redis.cache.RedisCacheWriter.nonLockingRedisCacheWriter; |
| 18 | +import static org.assertj.core.api.Assertions.*; |
| 19 | +import static org.assertj.core.api.Assumptions.*; |
| 20 | +import static org.springframework.data.redis.cache.RedisCacheWriter.*; |
24 | 21 |
|
25 | 22 | import java.nio.charset.StandardCharsets; |
26 | 23 | import java.time.Duration; |
|
45 | 42 | import org.junit.jupiter.params.ParameterizedTest; |
46 | 43 | import org.junit.jupiter.params.provider.Arguments; |
47 | 44 | import org.junit.jupiter.params.provider.MethodSource; |
| 45 | + |
48 | 46 | import org.springframework.data.redis.cache.BatchStrategies.Keys; |
49 | 47 | import org.springframework.data.redis.connection.RedisConnection; |
50 | 48 | import org.springframework.data.redis.connection.RedisConnectionFactory; |
@@ -311,6 +309,8 @@ void evictShouldNonblockingDeleteEntry() { |
311 | 309 |
|
312 | 310 | doWithConnection(connection -> { |
313 | 311 | Awaitility.await().pollInSameThread().pollDelay(Duration.ZERO).until(() -> !connection.exists(binaryCacheKey)); |
| 312 | + Awaitility.await().pollInSameThread().pollDelay(Duration.ZERO) |
| 313 | + .until(() -> writer.getCacheStatistics(CACHE_NAME).getDeletes() > 0); |
314 | 314 | assertThat(connection.exists(binaryCacheKey)).isFalse(); |
315 | 315 | }); |
316 | 316 |
|
|
0 commit comments