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 9d23f8431a92f815b5bc92dcc61fadb4a8dc610d Author: Rémi Kowalski <[email protected]> AuthorDate: Thu May 16 14:17:22 2019 +0200 JAMES-2772 serialize compute new mod seq and update flags using concatMap on the message flux --- .../apache/james/mailbox/cassandra/mail/CassandraMessageMapper.java | 3 +-- 1 file changed, 1 insertion(+), 2 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 7603319..bdbf91b 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 @@ -319,8 +319,7 @@ public class CassandraMessageMapper implements MessageMapper { private Mono<FlagsUpdateStageResult> runUpdateStage(CassandraId mailboxId, Flux<ComposedMessageIdWithMetaData> toBeUpdated, FlagsUpdateCalculator flagsUpdateCalculator) { Mono<Long> newModSeq = computeNewModSeq(mailboxId); return toBeUpdated - .limitRate(1) - .flatMapSequential(metadata -> newModSeq.flatMap(modSeq -> tryFlagsUpdate(flagsUpdateCalculator, modSeq, metadata))) + .concatMap(metadata -> newModSeq.flatMap(modSeq -> tryFlagsUpdate(flagsUpdateCalculator, modSeq, metadata))) .reduce(FlagsUpdateStageResult.none(), FlagsUpdateStageResult::merge) .flatMap(result -> updateIndexesForUpdatesResult(mailboxId, result)); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
