From 24975d366040674c5a9addc3a81760e89d5e6c37 Mon Sep 17 00:00:00 2001
From: jruaux <jruaux@gmail.com>
Date: Tue, 30 Apr 2024 13:16:26 -0700
Subject: [PATCH] test: Moved compareStreams to stack tests

---
 .../com/redis/spring/batch/test/BatchTests.java    | 13 -------------
 .../redis/spring/batch/test/StackToStackTests.java | 14 ++++++++++++++
 2 files changed, 14 insertions(+), 13 deletions(-)

diff --git a/subprojects/spring-batch-redis-test/src/test/java/com/redis/spring/batch/test/BatchTests.java b/subprojects/spring-batch-redis-test/src/test/java/com/redis/spring/batch/test/BatchTests.java
index 64a6782b..753f7490 100644
--- a/subprojects/spring-batch-redis-test/src/test/java/com/redis/spring/batch/test/BatchTests.java
+++ b/subprojects/spring-batch-redis-test/src/test/java/com/redis/spring/batch/test/BatchTests.java
@@ -231,19 +231,6 @@ void compareQuick(TestInfo info) throws Exception {
 		Assertions.assertEquals(sourceCount - targetCount, comparison.get(Status.MISSING).size());
 	}
 
-	@Test
-	void compareStreams(TestInfo info) throws Exception {
-		GeneratorItemReader gen = generator(10);
-		gen.setTypes(DataType.STREAM);
-		generate(info, gen);
-		RedisItemReader<String, String, MemKeyValue<String, Object>> reader = structReader(info);
-		RedisItemWriter<String, String, KeyValue<String, Object>> writer = RedisItemWriter.struct();
-		writer.setClient(targetRedisClient);
-		replicate(info, reader, writer);
-		KeyspaceComparison<String> comparison = compare(info);
-		Assertions.assertEquals(Collections.emptyList(), comparison.mismatches());
-	}
-
 	@Test
 	void compareStatus(TestInfo info) throws Exception {
 		GeneratorItemReader gen = generator(120);
diff --git a/subprojects/spring-batch-redis-test/src/test/java/com/redis/spring/batch/test/StackToStackTests.java b/subprojects/spring-batch-redis-test/src/test/java/com/redis/spring/batch/test/StackToStackTests.java
index 3b7031d4..fb6a0173 100644
--- a/subprojects/spring-batch-redis-test/src/test/java/com/redis/spring/batch/test/StackToStackTests.java
+++ b/subprojects/spring-batch-redis-test/src/test/java/com/redis/spring/batch/test/StackToStackTests.java
@@ -7,6 +7,7 @@
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -572,4 +573,17 @@ void writeStructMerge(TestInfo info) throws Exception {
 		assertEquals(10, actual.size());
 	}
 
+	@Test
+	void compareStreams(TestInfo info) throws Exception {
+		GeneratorItemReader gen = generator(10);
+		gen.setTypes(DataType.STREAM);
+		generate(info, gen);
+		RedisItemReader<String, String, MemKeyValue<String, Object>> reader = structReader(info);
+		RedisItemWriter<String, String, KeyValue<String, Object>> writer = RedisItemWriter.struct();
+		writer.setClient(targetRedisClient);
+		replicate(info, reader, writer);
+		KeyspaceComparison<String> comparison = compare(info);
+		Assertions.assertEquals(Collections.emptyList(), comparison.mismatches());
+	}
+
 }
\ No newline at end of file