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/08/10 02:47:49 UTC
[james-project] 19/23: JAMES-2629 Use a future supplier in
CassandraAsyncExecutor
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 <bt...@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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org