JAMES-2082 Use FluentFutureStream for storing attachments
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/b74540e5 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/b74540e5 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/b74540e5 Branch: refs/heads/master Commit: b74540e51bb329d92c22feaba9baba5a365d83dd Parents: 2209b4f Author: benwa <btell...@linagora.com> Authored: Sun Jul 9 22:17:31 2017 +0700 Committer: Antoine Duprat <adup...@linagora.com> Committed: Mon Jul 10 14:23:59 2017 +0200 ---------------------------------------------------------------------- .../mailbox/cassandra/mail/CassandraAttachmentMapper.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/b74540e5/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraAttachmentMapper.java ---------------------------------------------------------------------- diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraAttachmentMapper.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraAttachmentMapper.java index 1e661ce..5603895 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraAttachmentMapper.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraAttachmentMapper.java @@ -148,11 +148,10 @@ public class CassandraAttachmentMapper implements AttachmentMapper { @Override public void storeAttachments(Collection<Attachment> attachments) throws MailboxException { try { - CompletableFuture.allOf( - attachments.stream() - .map(Throwing.function(this::asyncStoreAttachment)) - .toArray(CompletableFuture[]::new) - ).join(); + FluentFutureStream.of( + attachments.stream() + .map(Throwing.function(this::asyncStoreAttachment))) + .join(); } catch (ThrownByLambdaException e) { throw new MailboxException(e.getCause().getMessage(), e.getCause()); } --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
