Add support for asynchronous retrieval from RedisCache

pom.xml

@@ -5,7 +5,7 @@
 
 	<groupId>org.springframework.data</groupId>
 	<artifactId>spring-data-redis</artifactId>
-	<version>3.2.0-SNAPSHOT</version>
+	<version>3.2.0-GH-2650-SNAPSHOT</version>
 
 	<name>Spring Data Redis</name>
 	<description>Spring Data module for Redis</description>

src/main/java/org/springframework/data/redis/aot/RedisRuntimeHints.java

@@ -106,6 +106,7 @@ public void registerHints(RuntimeHints hints, @Nullable ClassLoader classLoader)
 						TypeReference.of(ReactiveClusterScriptingCommands.class),
 						TypeReference.of(ReactiveClusterGeoCommands.class),
 						TypeReference.of(ReactiveClusterHyperLogLogCommands.class), TypeReference.of(ReactiveRedisOperations.class),
+						TypeReference.of(ReactiveRedisConnectionFactory.class),
 						TypeReference.of(ReactiveRedisTemplate.class), TypeReference.of(RedisOperations.class),
 						TypeReference.of(RedisTemplate.class), TypeReference.of(StringRedisTemplate.class),
 						TypeReference.of(KeyspaceConfiguration.class), TypeReference.of(MappingConfiguration.class),

src/main/java/org/springframework/data/redis/cache/BatchStrategies.java

@@ -28,18 +28,15 @@
 import org.springframework.util.Assert;
 
 /**
- * A collection of predefined {@link BatchStrategy} implementations using {@code KEYS} or {@code SCAN} command.
+ * Collection of predefined {@link BatchStrategy} implementations using the Redis {@code KEYS} or {@code SCAN} command.
  *
  * @author Mark Paluch
  * @author Christoph Strobl
+ * @author John Blum
  * @since 2.6
  */
 public abstract class BatchStrategies {
 
-	private BatchStrategies() {
-		// can't touch this - oh-oh oh oh oh-oh-oh
-	}
-
 	/**
 	 * A {@link BatchStrategy} using a single {@code KEYS} and {@code DEL} command to remove all matching keys.
 	 * {@code KEYS} scans the entire keyspace of the Redis database and can block the Redis worker thread for a long time
@@ -68,6 +65,10 @@ public static BatchStrategy scan(int batchSize) {
 		return new Scan(batchSize);
 	}
 
+	private BatchStrategies() {
+		// can't touch this - oh-oh oh oh oh-oh-oh
+	}
+
 	/**
 	 * {@link BatchStrategy} using {@code KEYS}.
 	 */
@@ -108,9 +109,11 @@ public long cleanCache(RedisConnection connection, String name, byte[] pattern)
 			long count = 0;
 
 			PartitionIterator<byte[]> partitions = new PartitionIterator<>(cursor, batchSize);
+
 			while (partitions.hasNext()) {
 
 				List<byte[]> keys = partitions.next();
+
 				count += keys.size();
 
 				if (keys.size() > 0) {
@@ -141,7 +144,7 @@ static class PartitionIterator<T> implements Iterator<List<T>> {
 
 		@Override
 		public boolean hasNext() {
-			return iterator.hasNext();
+			return this.iterator.hasNext();
 		}
 
 		@Override
@@ -151,9 +154,10 @@ public List<T> next() {
 				throw new NoSuchElementException();
 			}
 
-			List<T> list = new ArrayList<>(size);
-			while (list.size() < size && iterator.hasNext()) {
-				list.add(iterator.next());
+			List<T> list = new ArrayList<>(this.size);
+
+			while (list.size() < this.size && this.iterator.hasNext()) {
+				list.add(this.iterator.next());
 			}
 
 			return list;