ReplicationIT: Use streams to simplify Replace a couple for loops with stream.forEach(). Change-Id: I7408bd24c1323737ed3d83b53ecb24a0b2db95c4
diff --git a/src/test/java/com/googlesource/gerrit/plugins/replication/ReplicationIT.java b/src/test/java/com/googlesource/gerrit/plugins/replication/ReplicationIT.java index 433f2b5..fed69d9 100644 --- a/src/test/java/com/googlesource/gerrit/plugins/replication/ReplicationIT.java +++ b/src/test/java/com/googlesource/gerrit/plugins/replication/ReplicationIT.java
@@ -270,9 +270,7 @@ .scheduleFullSync(project, urlMatch, new ReplicationState(NO_OP), true); assertThat(listIncompleteTasks(Pattern.quote(PushOne.ALL_REFS))).hasSize(1); - for (ReplicationTasksStorage.ReplicateRefUpdate task : listIncompleteTasks()) { - assertThat(task.uri).isEqualTo(expectedURI); - } + streamIncompleteTasks().forEach((task) -> assertThat(task.uri).isEqualTo(expectedURI)); } @Test @@ -291,9 +289,7 @@ .scheduleFullSync(project, urlMatch, new ReplicationState(NO_OP), true); assertThat(listIncompleteTasks()).hasSize(1); - for (ReplicationTasksStorage.ReplicateRefUpdate task : listIncompleteTasks()) { - assertThat(task.uri).isEqualTo(expectedURI); - } + streamIncompleteTasks().forEach((task) -> assertThat(task.uri).isEqualTo(expectedURI)); } @Test