DATAREDIS-1034 - Polishing.

Pre-allocate operations objects for immutable serializationContext in ReactiveRedisTemplate.

Original pull request: #479.

Author: mp911de

src/main/java/org/springframework/data/redis/core/ReactiveRedisTemplate.java

@@ -69,6 +69,14 @@ public class ReactiveRedisTemplate<K, V> implements ReactiveRedisOperations<K, V
 	private final RedisSerializationContext<K, V> serializationContext;
 	private final boolean exposeConnection;
 	private final ReactiveScriptExecutor<K> reactiveScriptExecutor;
+	private final ReactiveGeoOperations<K, V> geoOps;
+	private final ReactiveHashOperations<K, ?, ?> hashOps;
+	private final ReactiveHyperLogLogOperations<K, V> hllOps;
+	private final ReactiveListOperations<K, V> listOps;
+	private final ReactiveSetOperations<K, V> setOps;
+	private final ReactiveStreamOperations<K, ?, ?> streamOps;
+	private final ReactiveValueOperations<K, V> valueOps;
+	private final ReactiveZSetOperations<K, V> zsetOps;
 
 	/**
 	 * Creates new {@link ReactiveRedisTemplate} using given {@link ReactiveRedisConnectionFactory} and
@@ -100,6 +108,15 @@ public ReactiveRedisTemplate(ReactiveRedisConnectionFactory connectionFactory,
 		this.serializationContext = serializationContext;
 		this.exposeConnection = exposeConnection;
 		this.reactiveScriptExecutor = new DefaultReactiveScriptExecutor<>(connectionFactory, serializationContext);
+
+		this.geoOps = opsForGeo(serializationContext);
+		this.hashOps = opsForHash(serializationContext);
+		this.hllOps = opsForHyperLogLog(serializationContext);
+		this.listOps = opsForList(serializationContext);
+		this.setOps = opsForSet(serializationContext);
+		this.streamOps = opsForStream(serializationContext);
+		this.valueOps = opsForValue(serializationContext);
+		this.zsetOps = opsForZSet(serializationContext);
 	}
 
 	/**
@@ -343,7 +360,7 @@ public Mono<Long> delete(Publisher<K> keys) {
 		return createFlux(connection -> connection.keyCommands() //
 				.mDel(Flux.from(keys).map(this::rawKey).buffer(128)) //
 				.map(CommandResponse::getOutput)) //
-				.collect(Collectors.summingLong(value -> value));
+						.collect(Collectors.summingLong(value -> value));
 	}
 
 	/*
@@ -378,7 +395,7 @@ public Mono<Long> unlink(Publisher<K> keys) {
 		return createFlux(connection -> connection.keyCommands() //
 				.mUnlink(Flux.from(keys).map(this::rawKey).buffer(128)) //
 				.map(CommandResponse::getOutput)) //
-				.collect(Collectors.summingLong(value -> value));
+						.collect(Collectors.summingLong(value -> value));
 	}
 
 	/*
@@ -530,7 +547,7 @@ protected ReactiveRedisConnection createRedisConnectionProxy(ReactiveRedisConnec
 	 */
 	@Override
 	public ReactiveGeoOperations<K, V> opsForGeo() {
-		return opsForGeo(serializationContext);
+		return geoOps;
 	}
 
 	/*
@@ -547,8 +564,9 @@ public <K1, V1> ReactiveGeoOperations<K1, V1> opsForGeo(RedisSerializationContex
 	 * @see org.springframework.data.redis.core.ReactiveRedisOperations#opsForHash()
 	 */
 	@Override
+	@SuppressWarnings("unchecked")
 	public <HK, HV> ReactiveHashOperations<K, HK, HV> opsForHash() {
-		return opsForHash(serializationContext);
+		return (ReactiveHashOperations<K, HK, HV>) hashOps;
 	}
 
 	/*
@@ -567,7 +585,7 @@ public <K1, HK, HV> ReactiveHashOperations<K1, HK, HV> opsForHash(
 	 */
 	@Override
 	public ReactiveHyperLogLogOperations<K, V> opsForHyperLogLog() {
-		return opsForHyperLogLog(serializationContext);
+		return hllOps;
 	}
 
 	/*
@@ -586,7 +604,7 @@ public <K1, V1> ReactiveHyperLogLogOperations<K1, V1> opsForHyperLogLog(
 	 */
 	@Override
 	public ReactiveListOperations<K, V> opsForList() {
-		return opsForList(serializationContext);
+		return listOps;
 	}
 
 	/*
@@ -604,7 +622,7 @@ public <K1, V1> ReactiveListOperations<K1, V1> opsForList(RedisSerializationCont
 	 */
 	@Override
 	public ReactiveSetOperations<K, V> opsForSet() {
-		return opsForSet(serializationContext);
+		return setOps;
 	}
 
 	/*
@@ -621,16 +639,18 @@ public <K1, V1> ReactiveSetOperations<K1, V1> opsForSet(RedisSerializationContex
 	 * @see org.springframework.data.redis.core.ReactiveRedisOperations#opsForStream()
 	 */
 	@Override
+	@SuppressWarnings("unchecked")
 	public <HK, HV> ReactiveStreamOperations<K, HK, HV> opsForStream() {
-		return opsForStream(serializationContext);
+		return (ReactiveStreamOperations<K, HK, HV>) streamOps;
 	}
 
 	/*
 	 * (non-Javadoc)
 	 * @see org.springframework.data.redis.core.ReactiveRedisOperations#opsForStream(HashMapper)
 	 */
 	@Override
-	public <HK, HV> ReactiveStreamOperations<K, HK, HV> opsForStream(HashMapper<? super K, ? super HK, ? super HV> hashMapper) {
+	public <HK, HV> ReactiveStreamOperations<K, HK, HV> opsForStream(
+			HashMapper<? super K, ? super HK, ? super HV> hashMapper) {
 		return opsForStream(serializationContext, hashMapper);
 	}
 
@@ -645,7 +665,8 @@ public <HK, HV> ReactiveStreamOperations<K, HK, HV> opsForStream(
 	}
 
 	protected <HK, HV> ReactiveStreamOperations<K, HK, HV> opsForStream(
-			RedisSerializationContext<K, ?> serializationContext, @Nullable HashMapper<? super K, ? super HK, ? super HV> hashMapper) {
+			RedisSerializationContext<K, ?> serializationContext,
+			@Nullable HashMapper<? super K, ? super HK, ? super HV> hashMapper) {
 		return new DefaultReactiveStreamOperations<>(this, serializationContext, hashMapper);
 	}
 
@@ -655,7 +676,7 @@ protected <HK, HV> ReactiveStreamOperations<K, HK, HV> opsForStream(
 	 */
 	@Override
 	public ReactiveValueOperations<K, V> opsForValue() {
-		return opsForValue(serializationContext);
+		return valueOps;
 	}
 
 	/*
@@ -673,7 +694,7 @@ public <K1, V1> ReactiveValueOperations<K1, V1> opsForValue(RedisSerializationCo
 	 */
 	@Override
 	public ReactiveZSetOperations<K, V> opsForZSet() {
-		return opsForZSet(serializationContext);
+		return zsetOps;
 	}
 
 	/*