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 <btell...@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-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org
