Skip to content

Commit eafb8f5

Browse files
Replace usage of DEBUG command.
1 parent 1114ed7 commit eafb8f5

File tree

3 files changed

+10
-7
lines changed

3 files changed

+10
-7
lines changed

src/test/java/org/springframework/data/redis/connection/AbstractConnectionIntegrationTests.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -28,13 +28,15 @@
2828
import static org.springframework.data.redis.connection.RedisGeoCommands.GeoSearchStoreCommandArgs.*;
2929
import static org.springframework.data.redis.core.ScanOptions.*;
3030

31+
import java.nio.charset.StandardCharsets;
3132
import java.time.Duration;
3233
import java.time.Instant;
3334
import java.time.temporal.ChronoUnit;
3435
import java.util.*;
3536
import java.util.concurrent.BlockingDeque;
3637
import java.util.concurrent.LinkedBlockingDeque;
3738
import java.util.concurrent.TimeUnit;
39+
import java.util.stream.IntStream;
3840

3941
import org.assertj.core.data.Offset;
4042
import org.junit.AssumptionViolatedException;
@@ -2661,10 +2663,11 @@ private static List<String> toList(Cursor<byte[]> cursor) {
26612663
}
26622664

26632665
@Test // DATAREDIS-417
2664-
@DisabledOnOs(value = MAC, architectures = "aarch64")
2665-
public void scanShouldReadEntireValueRangeWhenIdividualScanIterationsReturnEmptyCollection() {
2666+
public void scanShouldReadEntireValueRangeWhenIndividualScanIterationsReturnEmptyCollection() {
26662667

2667-
connection.execute("DEBUG", "POPULATE".getBytes(), "100".getBytes());
2668+
byteConnection.openPipeline();
2669+
IntStream.range(0, 100).forEach(it -> byteConnection.stringCommands().set("key:%s".formatted(it).getBytes(StandardCharsets.UTF_8), "data".getBytes(StandardCharsets.UTF_8)));
2670+
byteConnection.closePipeline();
26682671

26692672
Cursor<byte[]> cursor = connection.scan(ScanOptions.scanOptions().match("key*9").count(10).build());
26702673

src/test/java/org/springframework/data/redis/connection/AbstractConnectionPipelineIntegrationTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -149,8 +149,8 @@ public void testClosePipelineNotOpen() {
149149
@Test // DATAREDIS-417
150150
@Disabled
151151
@Override
152-
public void scanShouldReadEntireValueRangeWhenIdividualScanIterationsReturnEmptyCollection() {
153-
super.scanShouldReadEntireValueRangeWhenIdividualScanIterationsReturnEmptyCollection();
152+
public void scanShouldReadEntireValueRangeWhenIndividualScanIterationsReturnEmptyCollection() {
153+
super.scanShouldReadEntireValueRangeWhenIndividualScanIterationsReturnEmptyCollection();
154154
}
155155

156156
@Override

src/test/java/org/springframework/data/redis/connection/AbstractConnectionTransactionIntegrationTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -144,8 +144,8 @@ public void testScriptKill() {
144144
@Test // DATAREDIS-417
145145
@Disabled
146146
@Override
147-
public void scanShouldReadEntireValueRangeWhenIdividualScanIterationsReturnEmptyCollection() {
148-
super.scanShouldReadEntireValueRangeWhenIdividualScanIterationsReturnEmptyCollection();
147+
public void scanShouldReadEntireValueRangeWhenIndividualScanIterationsReturnEmptyCollection() {
148+
super.scanShouldReadEntireValueRangeWhenIndividualScanIterationsReturnEmptyCollection();
149149
}
150150

151151
@Override

0 commit comments

Comments
 (0)