Polishing.

Consistent operations documentation wording.

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

@@ -328,7 +328,7 @@ private V readValue(ByteBuffer buffer) {
 
 	private GeoResult<GeoLocation<V>> readGeoResult(GeoResult<GeoLocation<ByteBuffer>> source) {
 
-		return new GeoResult<>(new GeoLocation(readValue(source.getContent().getName()), source.getContent().getPoint()),
+		return new GeoResult<>(new GeoLocation<>(readValue(source.getContent().getName()), source.getContent().getPoint()),
 				source.getDistance());
 	}
 }

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

@@ -35,7 +35,7 @@
 import org.springframework.data.redis.domain.geo.GeoShape;
 
 /**
- * Reactive Redis operations for geo commands.
+ * Reactive Redis operations for Geo Commands.
  *
  * @author Mark Paluch
  * @author Christoph Strobl

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

@@ -24,7 +24,7 @@
 import java.util.Map;
 
 /**
- * Redis map specific operations working on a hash.
+ * Reactive Redis operations for Hash Commands.
  * <p>
  * Streams of methods returning {@code Mono<K>} or {@code Flux<M>} are terminated with
  * {@link org.springframework.dao.InvalidDataAccessApiUsageException} when

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

@@ -18,7 +18,7 @@
 import reactor.core.publisher.Mono;
 
 /**
- * Redis cardinality specific operations working on a HyperLogLog multiset.
+ * Reactive Redis operations for working on a HyperLogLog multiset.
  *
  * @author Mark Paluch
  * @since 2.0

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

@@ -29,7 +29,7 @@
 import org.springframework.util.Assert;
 
 /**
- * Redis list specific operations.
+ * Reactive Redis operations for List Commands.
  * <p>
  * Streams of methods returning {@code Mono<K>} or {@code Flux<M>} are terminated with
  * {@link org.springframework.dao.InvalidDataAccessApiUsageException} when

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

@@ -23,7 +23,7 @@
 import java.util.Map;
 
 /**
- * Redis set specific operations.
+ * Reactive Redis operations for Set Commands.
  * <p>
  * Streams of methods returning {@code Mono<K>} or {@code Flux<M>} are terminated with
  * {@link org.springframework.dao.InvalidDataAccessApiUsageException} when

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

@@ -23,32 +23,20 @@
 import java.util.Map;
 
 import org.reactivestreams.Publisher;
-
 import org.springframework.data.domain.Range;
 import org.springframework.data.redis.connection.Limit;
 import org.springframework.data.redis.connection.RedisStreamCommands.XClaimOptions;
-import org.springframework.data.redis.connection.stream.ByteBufferRecord;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ObjectRecord;
-import org.springframework.data.redis.connection.stream.PendingMessage;
-import org.springframework.data.redis.connection.stream.PendingMessages;
-import org.springframework.data.redis.connection.stream.PendingMessagesSummary;
-import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.*;
 import org.springframework.data.redis.connection.stream.Record;
-import org.springframework.data.redis.connection.stream.RecordId;
 import org.springframework.data.redis.connection.stream.StreamInfo.XInfoConsumer;
 import org.springframework.data.redis.connection.stream.StreamInfo.XInfoGroup;
 import org.springframework.data.redis.connection.stream.StreamInfo.XInfoStream;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.connection.stream.StreamReadOptions;
-import org.springframework.data.redis.connection.stream.StreamRecords;
 import org.springframework.data.redis.hash.HashMapper;
 import org.springframework.lang.Nullable;
 import org.springframework.util.Assert;
 
 /**
- * Redis stream specific operations.
+ * Reactive Redis operations for Stream Commands.
  *
  * @author Mark Paluch
  * @author Christoph Strobl

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

@@ -33,7 +33,7 @@
 import org.springframework.lang.Nullable;
 
 /**
- * Redis ZSet/sorted set specific operations.
+ * Reactive Redis operations for Sorted (ZSet) Commands.
  * <p>
  * Streams of methods returning {@code Mono<K>} or {@code Flux<M>} are terminated with
  * {@link org.springframework.dao.InvalidDataAccessApiUsageException} when