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 ro...@apache.org on 2020/06/11 15:25:53 UTC
[james-project] 16/17: JAMES-3204 Flatten reactive calls in
CassandraMailboxMapper::findInMailboxReactive
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 <bt...@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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org