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 rc...@apache.org on 2020/05/13 02:48:34 UTC
[james-project] 02/05: JAMES-3155
ComputeMessageFastViewProjectionListener can retrieve messages reactively
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 1e69f1ff4c800b4201b865709a0d832f1158ca52
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Tue May 12 11:45:13 2020 +0700
JAMES-3155 ComputeMessageFastViewProjectionListener can retrieve messages reactively
---
.../james/jmap/event/ComputeMessageFastViewProjectionListener.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/server/protocols/jmap-draft/src/main/java/org/apache/james/jmap/event/ComputeMessageFastViewProjectionListener.java b/server/protocols/jmap-draft/src/main/java/org/apache/james/jmap/event/ComputeMessageFastViewProjectionListener.java
index 2100dc3..af1dbc9 100644
--- a/server/protocols/jmap-draft/src/main/java/org/apache/james/jmap/event/ComputeMessageFastViewProjectionListener.java
+++ b/server/protocols/jmap-draft/src/main/java/org/apache/james/jmap/event/ComputeMessageFastViewProjectionListener.java
@@ -80,9 +80,7 @@ public class ComputeMessageFastViewProjectionListener implements MailboxListener
}
private Mono<Void> handleAddedEvent(Added addedEvent, MailboxSession session) {
- return Mono.fromCallable(() -> messageIdManager.getMessages(addedEvent.getMessageIds(), FetchGroup.FULL_CONTENT, session))
- .subscribeOn(Schedulers.elastic())
- .flatMapMany(Flux::fromIterable)
+ return Flux.from(messageIdManager.getMessagesReactive(addedEvent.getMessageIds(), FetchGroup.FULL_CONTENT, session))
.flatMap(Throwing.function(messageResult -> Mono.fromCallable(
() -> Pair.of(messageResult.getMessageId(), computeFastViewPrecomputedProperties(messageResult)))
.subscribeOn(Schedulers.parallel())))
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org