Skip to content

Commit 23c6ecf

Browse files
committed
Polishing.
Consistent operations documentation wording.
1 parent be7c590 commit 23c6ecf

8 files changed

+9
-21
lines changed

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -326,7 +326,7 @@ private V readValue(ByteBuffer buffer) {
326326

327327
private GeoResult<GeoLocation<V>> readGeoResult(GeoResult<GeoLocation<ByteBuffer>> source) {
328328

329-
return new GeoResult<>(new GeoLocation(readValue(source.getContent().getName()), source.getContent().getPoint()),
329+
return new GeoResult<>(new GeoLocation<>(readValue(source.getContent().getName()), source.getContent().getPoint()),
330330
source.getDistance());
331331
}
332332
}

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@
3737
import org.springframework.data.redis.domain.geo.GeoShape;
3838

3939
/**
40-
* Reactive Redis operations for geo commands.
40+
* Reactive Redis operations for Geo Commands.
4141
* <p>
4242
* Methods returning top-level values such as {@code Mono<K>} or {@code Flux<M>} are subject to
4343
* {@link Flux#mapNotNull(Function) element filtering} when

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
import java.util.function.Function;
2626

2727
/**
28-
* Redis map specific operations working on a hash.
28+
* Reactive Redis operations for Hash Commands.
2929
* <p>
3030
* Methods returning top-level values such as {@code Mono<K>} or {@code Flux<M>} are subject to
3131
* {@link Flux#mapNotNull(Function) element filtering} when

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
import reactor.core.publisher.Mono;
1919

2020
/**
21-
* Redis cardinality specific operations working on a HyperLogLog multiset.
21+
* Reactive Redis operations for working on a HyperLogLog multiset.
2222
*
2323
* @author Mark Paluch
2424
* @since 2.0

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
import org.springframework.util.Assert;
3131

3232
/**
33-
* Redis list specific operations.
33+
* Reactive Redis operations for List Commands.
3434
* <p>
3535
* Methods returning top-level values such as {@code Mono<K>} or {@code Flux<M>} are subject to
3636
* {@link Flux#mapNotNull(Function) element filtering} when

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
import java.util.function.Function;
2525

2626
/**
27-
* Redis set specific operations.
27+
* Reactive Redis operations for Set Commands.
2828
* <p>
2929
* Methods returning top-level values such as {@code Mono<K>} or {@code Flux<M>} are subject to
3030
* {@link Flux#mapNotNull(Function) element filtering} when

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

+2-14
Original file line numberDiff line numberDiff line change
@@ -23,32 +23,20 @@
2323
import java.util.Map;
2424

2525
import org.reactivestreams.Publisher;
26-
2726
import org.springframework.data.domain.Range;
2827
import org.springframework.data.redis.connection.Limit;
2928
import org.springframework.data.redis.connection.RedisStreamCommands.XClaimOptions;
30-
import org.springframework.data.redis.connection.stream.ByteBufferRecord;
31-
import org.springframework.data.redis.connection.stream.Consumer;
32-
import org.springframework.data.redis.connection.stream.MapRecord;
33-
import org.springframework.data.redis.connection.stream.ObjectRecord;
34-
import org.springframework.data.redis.connection.stream.PendingMessage;
35-
import org.springframework.data.redis.connection.stream.PendingMessages;
36-
import org.springframework.data.redis.connection.stream.PendingMessagesSummary;
37-
import org.springframework.data.redis.connection.stream.ReadOffset;
29+
import org.springframework.data.redis.connection.stream.*;
3830
import org.springframework.data.redis.connection.stream.Record;
39-
import org.springframework.data.redis.connection.stream.RecordId;
4031
import org.springframework.data.redis.connection.stream.StreamInfo.XInfoConsumer;
4132
import org.springframework.data.redis.connection.stream.StreamInfo.XInfoGroup;
4233
import org.springframework.data.redis.connection.stream.StreamInfo.XInfoStream;
43-
import org.springframework.data.redis.connection.stream.StreamOffset;
44-
import org.springframework.data.redis.connection.stream.StreamReadOptions;
45-
import org.springframework.data.redis.connection.stream.StreamRecords;
4634
import org.springframework.data.redis.hash.HashMapper;
4735
import org.springframework.lang.Nullable;
4836
import org.springframework.util.Assert;
4937

5038
/**
51-
* Redis stream specific operations.
39+
* Reactive Redis operations for Stream Commands.
5240
*
5341
* @author Mark Paluch
5442
* @author Christoph Strobl

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
import org.springframework.lang.Nullable;
3535

3636
/**
37-
* Redis ZSet/sorted set specific operations.
37+
* Reactive Redis operations for Sorted (ZSet) Commands.
3838
* <p>
3939
* Methods returning top-level values such as {@code Mono<K>} or {@code Flux<M>} are subject to
4040
* {@link Flux#mapNotNull(Function) element filtering} when

0 commit comments

Comments
 (0)