diff --git a/src/main/java/org/springframework/data/redis/core/ReactiveRedisTemplate.java b/src/main/java/org/springframework/data/redis/core/ReactiveRedisTemplate.java index db578787a..814062fea 100644 --- a/src/main/java/org/springframework/data/redis/core/ReactiveRedisTemplate.java +++ b/src/main/java/org/springframework/data/redis/core/ReactiveRedisTemplate.java @@ -69,6 +69,14 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations serializationContext; private final boolean exposeConnection; private final ReactiveScriptExecutor reactiveScriptExecutor; + private final ReactiveGeoOperations geoOps; + private final ReactiveHashOperations hashOps; + private final ReactiveHyperLogLogOperations hllOps; + private final ReactiveListOperations listOps; + private final ReactiveSetOperations setOps; + private final ReactiveStreamOperations streamOps; + private final ReactiveValueOperations valueOps; + private final ReactiveZSetOperations zsetOps; /** * Creates new {@link ReactiveRedisTemplate} using given {@link ReactiveRedisConnectionFactory} and @@ -100,6 +108,15 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations(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 class ReactiveRedisTemplate implements ReactiveRedisOperations 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 class ReactiveRedisTemplate implements ReactiveRedisOperations 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 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations opsForGeo() { - return opsForGeo(serializationContext); + return geoOps; } /* @@ -547,8 +564,9 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations ReactiveHashOperations opsForHash() { - return opsForHash(serializationContext); + return (ReactiveHashOperations) hashOps; } /* @@ -567,7 +585,7 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations opsForHyperLogLog() { - return opsForHyperLogLog(serializationContext); + return hllOps; } /* @@ -586,7 +604,7 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations opsForList() { - return opsForList(serializationContext); + return listOps; } /* @@ -604,7 +622,7 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations opsForSet() { - return opsForSet(serializationContext); + return setOps; } /* @@ -621,8 +639,9 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations ReactiveStreamOperations opsForStream() { - return opsForStream(serializationContext); + return (ReactiveStreamOperations) streamOps; } /* @@ -630,7 +649,8 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations ReactiveStreamOperations opsForStream(HashMapper hashMapper) { + public ReactiveStreamOperations opsForStream( + HashMapper hashMapper) { return opsForStream(serializationContext, hashMapper); } @@ -645,7 +665,8 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations ReactiveStreamOperations opsForStream( - RedisSerializationContext serializationContext, @Nullable HashMapper hashMapper) { + RedisSerializationContext serializationContext, + @Nullable HashMapper hashMapper) { return new DefaultReactiveStreamOperations<>(this, serializationContext, hashMapper); } @@ -655,7 +676,7 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations opsForValue() { - return opsForValue(serializationContext); + return valueOps; } /* @@ -673,7 +694,7 @@ public class ReactiveRedisTemplate implements ReactiveRedisOperations opsForZSet() { - return opsForZSet(serializationContext); + return zsetOps; } /*