You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by ad...@apache.org on 2017/07/10 17:54:43 UTC
[31/41] james-project git commit: JAMES-2082 Use FluentFutureStream
for storing attachments
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 <bt...@linagora.com>
Authored: Sun Jul 9 22:17:31 2017 +0700
Committer: Antoine Duprat <ad...@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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org