[james-project] 13/14: JAMES-3149 MessageFastViewProjection should not specify a scheduler

[rc...@apache.org]

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 f3ade3bcd851baafe7dfae91d7f9b608b2367ebb
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Tue Apr 28 11:49:34 2020 +0700

    JAMES-3149 MessageFastViewProjection should not specify a scheduler
---
 .../apache/james/jmap/api/projections/MessageFastViewProjection.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/server/data/data-jmap/src/main/java/org/apache/james/jmap/api/projections/MessageFastViewProjection.java b/server/data/data-jmap/src/main/java/org/apache/james/jmap/api/projections/MessageFastViewProjection.java
index afc3e15..dda6417 100644
--- a/server/data/data-jmap/src/main/java/org/apache/james/jmap/api/projections/MessageFastViewProjection.java
+++ b/server/data/data-jmap/src/main/java/org/apache/james/jmap/api/projections/MessageFastViewProjection.java
@@ -30,7 +30,6 @@ import com.google.common.base.Preconditions;
 
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
-import reactor.core.scheduler.Schedulers;
 
 public interface MessageFastViewProjection {
 
@@ -52,7 +51,6 @@ public interface MessageFastViewProjection {
         return Flux.fromIterable(messageIds)
             .flatMap(messageId -> Mono.from(this.retrieve(messageId))
                 .map(preview -> Pair.of(messageId, preview)))
-            .collectMap(Pair::getLeft, Pair::getRight)
-            .subscribeOn(Schedulers.elastic());
+            .collectMap(Pair::getLeft, Pair::getRight);
     }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org