This is an automated email from the ASF dual-hosted git repository. rouazana pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 4c093a4e99d8060d547488725411a8cc3965c2b2 Author: Benoit Tellier <btell...@linagora.com> AuthorDate: Mon Jun 8 14:12:01 2020 +0700 JAMES-3204 Flatten reactive calls in CassandraMailboxMapper::findInMailboxReactive --- .../apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java index 2e41530..9b8c18e 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java @@ -170,10 +170,8 @@ public class CassandraMessageMapper implements MessageMapper { public Flux<MailboxMessage> findInMailboxReactive(Mailbox mailbox, MessageRange messageRange, FetchType ftype, int limit) { CassandraId mailboxId = (CassandraId) mailbox.getMailboxId(); - return Limit.from(limit).applyOnFlux( - messageIdDAO.retrieveMessages(mailboxId, messageRange) - .flatMap(id -> retrieveMessage(id, ftype), cassandraConfiguration.getMessageReadChunkSize())) - .map(MailboxMessage.class::cast) + return Limit.from(limit).applyOnFlux(messageIdDAO.retrieveMessages(mailboxId, messageRange)) + .flatMap(id -> retrieveMessage(id, ftype), cassandraConfiguration.getMessageReadChunkSize()) .sort(Comparator.comparing(MailboxMessage::getUid)); } --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org