Skip to content

Commit

Permalink
refactor!: Renamed internal lmethod
Browse files Browse the repository at this point in the history
  • Loading branch information
jruaux committed May 25, 2024
1 parent 5ec9cad commit 086bdea
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions plugins/riot/src/main/java/com/redis/riot/Replicate.java
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ public void copyTo(Replicate target) {
@Override
protected Job job() {
List<Step<?, ?>> steps = new ArrayList<>();
Step<KeyValue<byte[], ?>, KeyValue<byte[], ?>> replicateStep = step();
Step<KeyValue<byte[], ?>, KeyValue<byte[], ?>> replicateStep = replicateStep();
ItemProcessor<KeyValue<byte[], ?>, KeyValue<byte[], ?>> processor = processor();
replicateStep.processor(processor);
steps.add(replicateStep);
Expand Down Expand Up @@ -92,7 +92,7 @@ protected Job job() {
return RiotUtils.processor(code, processor, decode);
}

private Step<KeyValue<byte[], ?>, KeyValue<byte[], ?>> step() {
private Step<KeyValue<byte[], ?>, KeyValue<byte[], ?>> replicateStep() {
RedisItemReader<byte[], byte[], KeyValue<byte[], ?>> reader = reader();
configure(reader);
RedisItemWriter<byte[], byte[], KeyValue<byte[], ?>> writer = writer();
Expand Down

0 comments on commit 086bdea

Please sign in to comment.