From d57e908e5acee780eb4ad27d1899470eb0686017 Mon Sep 17 00:00:00 2001 From: David Pursehouse Date: Tue, 25 Oct 2016 19:19:22 +0900 Subject: [PATCH 1/2] ChangeData: Replace FluentIterable with Java 8 stream Change-Id: I3d5172b4e2c81ba3aa00810b8be9474f1daf779f --- .../com/google/gerrit/server/query/change/ChangeData.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/query/change/ChangeData.java b/gerrit-server/src/main/java/com/google/gerrit/server/query/change/ChangeData.java index eaec021b09..223e8c755d 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/query/change/ChangeData.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/query/change/ChangeData.java @@ -17,11 +17,10 @@ package com.google.gerrit.server.query.change; import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.base.Preconditions.checkState; import static com.google.gerrit.server.ApprovalsUtil.sortApprovals; +import static java.util.stream.Collectors.toList; import com.google.auto.value.AutoValue; import com.google.common.base.MoreObjects; -import com.google.common.base.Predicate; -import com.google.common.collect.FluentIterable; import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableListMultimap; import com.google.common.collect.ImmutableMultimap; @@ -94,6 +93,7 @@ import java.util.List; import java.util.Map; import java.util.Optional; import java.util.Set; +import java.util.function.Predicate; public class ChangeData { private static final int BATCH_SIZE = 50; @@ -898,14 +898,14 @@ public class ChangeData { * @throws OrmException an error occurred reading the database. */ public Collection visiblePatchSets() throws OrmException { - Predicate predicate = ps -> { + Predicate predicate = ps -> { try { return changeControl().isPatchVisible(ps, db); } catch (OrmException e) { return false; } }; - return FluentIterable.from(patchSets()).filter(predicate).toList(); + return patchSets().stream().filter(predicate).collect(toList()); } public void setPatchSets(Collection patchSets) { From 765fc273fc23fd93d4ca0c51bd2e6aaa1108a3e3 Mon Sep 17 00:00:00 2001 From: David Pursehouse Date: Tue, 25 Oct 2016 19:39:37 +0900 Subject: [PATCH 2/2] ChangeData#asMap: Use Java 8 stream Change-Id: Iafcc3fbd3e85f11e23462dfa7f04ef79fcf1d544 --- .../google/gerrit/server/query/change/ChangeData.java | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/query/change/ChangeData.java b/gerrit-server/src/main/java/com/google/gerrit/server/query/change/ChangeData.java index 223e8c755d..3387f0642f 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/query/change/ChangeData.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/query/change/ChangeData.java @@ -94,6 +94,7 @@ import java.util.Map; import java.util.Optional; import java.util.Set; import java.util.function.Predicate; +import java.util.stream.Collectors; public class ChangeData { private static final int BATCH_SIZE = 50; @@ -108,12 +109,8 @@ public class ChangeData { } public static Map asMap(List changes) { - Map result = - Maps.newHashMapWithExpectedSize(changes.size()); - for (ChangeData cd : changes) { - result.put(cd.getId(), cd); - } - return result; + return changes.stream().collect( + Collectors.toMap(ChangeData::getId, cd -> cd)); } public static void ensureChangeLoaded(Iterable changes)