Issue #15: Switch to Reactor 3.1.0

primeval-io · Oct 16, 2017 · a7ca0ab · a7ca0ab
1 parent 3c06918
commit a7ca0ab
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/pom.xml b/pom.xml
@@ -21,7 +21,7 @@
 
 	<properties>
 		<primeval-commons.version>1.1.0-SNAPSHOT</primeval-commons.version>
-		<reactor-core.version>3.0.7.RELEASE</reactor-core.version>
+		<reactor-core.version>3.1.0.RELEASE</reactor-core.version>
 	</properties>
 
 	<dependencies>
@@ -30,7 +30,7 @@
 			<artifactId>primeval-commons</artifactId>
 			<version>${primeval-commons.version}</version>
 		</dependency>
-		
+
 		<dependency>
 			<groupId>org.osgi</groupId>
 			<artifactId>org.osgi.core</artifactId>

diff --git a/src/main/java/io/primeval/codex/promise/PromiseHelper.java b/src/main/java/io/primeval/codex/promise/PromiseHelper.java
@@ -194,16 +194,16 @@ public static <T> Mono<T> toMonoOptional(Promise<Optional<T>> promise) {
     }
 
     public static <T> Mono<T> toMono(Callable<Promise<T>> promise) {
-        return Mono.fromCallable(promise).then(PromiseHelper::toMono);
+        return Mono.fromCallable(promise).flatMap(PromiseHelper::toMono);
     }
 
     public static <T> Mono<T> toMonoOptional(Callable<Promise<Optional<T>>> promise) {
-        return Mono.fromCallable(promise).then(PromiseHelper::toMonoOptional);
+        return Mono.fromCallable(promise).flatMap(PromiseHelper::toMonoOptional);
     }
 
     public static <T> Promise<T> fromMono(Mono<T> mono) {
         Deferred<T> deferred = new Deferred<>();
-        mono.doOnTerminate((value, error) -> {
+        mono.doOnSuccessOrError((value, error) -> {
             if (error != null) {
                 deferred.fail(error);
             } else {