[james-project] 19/23: JAMES-2629 Use a future supplier in CassandraAsyncExecutor

[rcordier]

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 44c83bd8823baf69aecb23ae932589645219481c
Author: Benoit Tellier <btell...@linagora.com>
AuthorDate: Fri Jul 31 11:20:00 2020 +0700

    JAMES-2629 Use a future supplier in CassandraAsyncExecutor
    
    This allows getting rid of a Mono::defer call
---
 .../apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java
 
b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java
index 4005cc5..aa0c6cf 100644
--- 
a/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java
+++ 
b/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java
@@ -45,9 +45,9 @@ public class CassandraAsyncExecutor {
     }
 
     public Mono<ResultSet> execute(Statement statement) {
-        return Mono.defer(() -> Mono.fromFuture(FutureConverter
+        return Mono.fromFuture(() -> FutureConverter
                 .toCompletableFuture(session.executeAsync(statement)))
-                .publishOn(Schedulers.elastic()));
+                .publishOn(Schedulers.elastic());
     }
 
     public Mono<Boolean> executeReturnApplied(Statement statement) {


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