MAILBOX-297 Remove concurrent support for James chunker
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/32fa0542 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/32fa0542 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/32fa0542 Branch: refs/heads/master Commit: 32fa054267b26b450d1946bb5b932dfc8f992a0f Parents: e82c858 Author: benwa <[email protected]> Authored: Wed May 24 15:16:41 2017 +0700 Committer: benwa <[email protected]> Committed: Mon May 29 17:02:50 2017 +0700 ---------------------------------------------------------------------- .../java/org/apache/james/util/streams/JamesCollectors.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/32fa0542/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java ---------------------------------------------------------------------- diff --git a/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java b/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java index adfac75..e705063 100644 --- a/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java +++ b/server/container/util-java8/src/main/java/org/apache/james/util/streams/JamesCollectors.java @@ -33,7 +33,6 @@ import com.google.common.base.Preconditions; import com.google.common.collect.ArrayListMultimap; import com.google.common.collect.ImmutableSet; import com.google.common.collect.Multimap; -import com.google.common.collect.Multimaps; public class JamesCollectors { public static <D> Collector<D, ?, Stream<Collection<D>>> chunker(int chunkSize) { @@ -52,7 +51,7 @@ public class JamesCollectors { @Override public Supplier<Multimap<Integer, D>> supplier() { - return () -> Multimaps.synchronizedListMultimap(ArrayListMultimap.<Integer, D>create()); + return ArrayListMultimap::create; } @Override @@ -75,7 +74,7 @@ public class JamesCollectors { @Override public Set<Characteristics> characteristics() { - return ImmutableSet.of(Characteristics.CONCURRENT); + return ImmutableSet.of(); } } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
