james-server-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rouaz...@apache.org
Subject [01/10] james-project git commit: JAMES-2612 Refactor MessageBatcher
Date Mon, 03 Dec 2018 10:17:23 GMT
Repository: james-project
Updated Branches:
  refs/heads/master ce8cf479a -> 0e3ffde31


JAMES-2612 Refactor MessageBatcher


Project: http://git-wip-us.apache.org/repos/asf/james-project/repo
Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/0e3ffde3
Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/0e3ffde3
Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/0e3ffde3

Branch: refs/heads/master
Commit: 0e3ffde315a977a4769d0c69a76743918da502f1
Parents: 48ef09c
Author: Antoine Duprat <aduprat@linagora.com>
Authored: Thu Nov 29 09:58:15 2018 +0100
Committer: Raphael Ouazana <raphael.ouazana@linagora.com>
Committed: Mon Dec 3 11:16:29 2018 +0100

----------------------------------------------------------------------
 .../org/apache/james/mailbox/store/MessageBatcher.java | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/james-project/blob/0e3ffde3/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java
----------------------------------------------------------------------
diff --git a/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java
b/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java
index 9f1fdc8..6c6509c 100644
--- a/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java
+++ b/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageBatcher.java
@@ -19,12 +19,13 @@
 
 package org.apache.james.mailbox.store;
 
-import java.util.ArrayList;
 import java.util.List;
 
 import org.apache.james.mailbox.exception.MailboxException;
 import org.apache.james.mailbox.model.MessageRange;
 
+import com.github.fge.lambdas.Throwing;
+import com.github.steveash.guavate.Guavate;
 import com.google.common.base.Preconditions;
 
 public class MessageBatcher {
@@ -48,11 +49,11 @@ public class MessageBatcher {
 
     public List<MessageRange> batchMessages(MessageRange set, BatchedOperation batchedOperation)
throws MailboxException {
         if (batchSize > 0) {
-            List<MessageRange> movedRanges = new ArrayList<>();
-            for (MessageRange messageRange : set.split(batchSize)) {
-                movedRanges.addAll(batchedOperation.execute(messageRange));
-            }
-            return movedRanges;
+            return set.split(batchSize)
+                .stream()
+                .flatMap(Throwing.function(range -> batchedOperation.execute(range)
+                                                                    .stream()))
+                .collect(Guavate.toImmutableList());
         } else {
             return batchedOperation.execute(set);
         }


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org


Mime
View raw message