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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
