You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2021/06/14 01:59:36 UTC
[james-project] 04/04: [PERFORMANCE] Avoid using Flux.from where
possible
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit fe8f9d14bd743d7bb861cd20effc7165888983a3
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Fri Jun 4 21:32:17 2021 +0700
[PERFORMANCE] Avoid using Flux.from where possible
---
.../java/org/apache/james/vault/blob/BlobStoreDeletedMessageVault.java | 2 +-
.../main/java/org/apache/james/mailbox/store/StoreMessageIdManager.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/mailbox/plugin/deleted-messages-vault/src/main/java/org/apache/james/vault/blob/BlobStoreDeletedMessageVault.java b/mailbox/plugin/deleted-messages-vault/src/main/java/org/apache/james/vault/blob/BlobStoreDeletedMessageVault.java
index bfac3aa..a9b5ed4 100644
--- a/mailbox/plugin/deleted-messages-vault/src/main/java/org/apache/james/vault/blob/BlobStoreDeletedMessageVault.java
+++ b/mailbox/plugin/deleted-messages-vault/src/main/java/org/apache/james/vault/blob/BlobStoreDeletedMessageVault.java
@@ -141,7 +141,7 @@ public class BlobStoreDeletedMessageVault implements DeletedMessageVault {
private Flux<DeletedMessage> searchOn(Username username, Query query) {
return Flux.from(messageMetadataVault.listRelatedBuckets())
- .concatMap(bucketName -> Flux.from(messageMetadataVault.listMessages(bucketName, username)))
+ .concatMap(bucketName -> messageMetadataVault.listMessages(bucketName, username))
.map(DeletedMessageWithStorageInformation::getDeletedMessage)
.filter(query.toPredicate());
}
diff --git a/mailbox/store/src/main/java/org/apache/james/mailbox/store/StoreMessageIdManager.java b/mailbox/store/src/main/java/org/apache/james/mailbox/store/StoreMessageIdManager.java
index 71f7ab4..e4062e4 100644
--- a/mailbox/store/src/main/java/org/apache/james/mailbox/store/StoreMessageIdManager.java
+++ b/mailbox/store/src/main/java/org/apache/james/mailbox/store/StoreMessageIdManager.java
@@ -186,7 +186,7 @@ public class StoreMessageIdManager implements MessageIdManager {
MessageIdMapper messageIdMapper = mailboxSessionMapperFactory.getMessageIdMapper(session);
int concurrency = 4;
return Flux.fromIterable(ids)
- .flatMap(id -> Flux.from(messageIdMapper.findMetadata(id)), concurrency)
+ .flatMap(messageIdMapper::findMetadata, concurrency)
.groupBy(metaData -> metaData.getComposedMessageId().getMailboxId())
.filterWhen(groupedFlux -> hasRightsOnMailboxReactive(session, Right.Read).apply(groupedFlux.key()), DEFAULT_CONCURRENCY)
.flatMap(Function.identity(), DEFAULT_CONCURRENCY);
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org