Repository: james-project Updated Branches: refs/heads/master df5d678cd -> e061ccb5c
JAMES-2630 Set CassandraAsyncExecutor.executeReactor to defer to ensure composability Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/ddb82362 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/ddb82362 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/ddb82362 Branch: refs/heads/master Commit: ddb82362177c54ad27ebff98cccf3436b4348446 Parents: df5d678 Author: Gautier DI FOLCO <gdifo...@linagora.com> Authored: Fri Jan 18 16:53:12 2019 +0100 Committer: Matthieu Baechler <matth...@apache.org> Committed: Mon Jan 28 15:30:13 2019 +0100 ---------------------------------------------------------------------- .../james/backends/cassandra/utils/CassandraAsyncExecutor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/ddb82362/backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/utils/CassandraAsyncExecutor.java ---------------------------------------------------------------------- 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 f1084f7..decfeda 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 @@ -65,9 +65,9 @@ public class CassandraAsyncExecutor { } public Mono<ResultSet> executeReactor(Statement statement) { - return Mono.fromFuture(FutureConverter + return Mono.defer(() -> Mono.fromFuture(FutureConverter .toCompletableFuture(session.executeAsync(statement))) - .publishOn(Schedulers.elastic()); + .publishOn(Schedulers.elastic())); } --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
