fix: Added compare reader initialization

jruaux · jruaux · commit c23a83fe7a2a · 2024-12-12T16:12:58.000-08:00
diff --git a/plugins/riot/src/main/java/com/redis/riot/AbstractReplicateCommand.java b/plugins/riot/src/main/java/com/redis/riot/AbstractReplicateCommand.java
@@ -115,6 +115,7 @@ protected KeyComparisonItemReader<byte[], byte[]> compareReader() {
 		KeyComparisonItemReader<byte[], byte[]> reader = new KeyComparisonItemReader<>(source, target);
 		reader.setComparator(keyComparator());
 		reader.setProcessor(processor());
+		configureAsyncReader(reader);
 		return reader;
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -115,6 +115,7 @@ protected KeyComparisonItemReader<byte[], byte[]> compareReader() {`
`115`	`115`	`KeyComparisonItemReader<byte[], byte[]> reader = new KeyComparisonItemReader<>(source, target);`
`116`	`116`	`reader.setComparator(keyComparator());`
`117`	`117`	`reader.setProcessor(processor());`
	`118`	`+ configureAsyncReader(reader);`
`118`	`119`	`return reader;`
`119`	`120`	`}`
`120`	`121`