Switch back to Reactor 3.0 snapshots

build.gradle

@@ -74,8 +74,8 @@ configure(allprojects) { project ->
 	ext.protobufVersion        = "3.0.0"
 	ext.reactivestreamsVersion = "1.0.0"
 	ext.reactorVersion         = "2.0.8.RELEASE"
-	ext.reactorCoreVersion     = '3.0.0.RC1'
+	ext.reactorCoreVersion     = '3.0.0.BUILD-SNAPSHOT'
-	ext.reactorNettyVersion    = '0.5.0.M2'
+	ext.reactorNettyVersion    = '0.5.0.BUILD-SNAPSHOT'
 	ext.romeVersion            = "1.6.0"
 	ext.rxjavaVersion          = '1.1.8'
 	ext.rxnettyVersion         = '0.5.2-rc.3'
@@ -160,6 +160,7 @@ configure(allprojects) { project ->
 	repositories {
 		maven { url "https://repo.spring.io/libs-release" }
 		maven { url "https://repo.spring.io/milestone" }
+		maven { url "https://repo.spring.io/snapshot" }	// Reactor 3 snapshots
 	}
 
 	dependencies {

spring-core/src/main/java/org/springframework/core/io/buffer/DataBufferUtils.java

@@ -184,7 +184,7 @@ public abstract class DataBufferUtils {
 				}
 			}
 			catch (IOException ex) {
-				sub.fail(ex);
+				sub.error(ex);
 			}
 			return channel;
 		}

spring-web-reactive/src/main/java/org/springframework/web/reactive/result/method/InvocableHandlerMethod.java

@@ -138,8 +138,9 @@ public class InvocableHandlerMethod extends HandlerMethod {
 					})
 					.collect(Collectors.toList());
 
-			return Mono.when(monos).log("reactor.unresolved").map(args ->
+			// Create Mono with array of resolved values...
-					Stream.of(args).map(o -> o != NO_VALUE ? o : null).toArray());
+			return Mono.when(monos,
+					args -> Stream.of(args).map(o -> o != NO_VALUE ? o : null).toArray());
 		}
 		catch (Throwable ex) {
 			return Mono.error(ex);

spring-web/src/test/java/org/springframework/http/server/reactive/ChannelSendOperatorTests.java

@@ -114,7 +114,7 @@ public class ChannelSendOperatorTests {
 			int i = ++idx;
 			subscriber.next(String.valueOf(i));
 			if (i == 3) {
-				subscriber.fail(error);
+				subscriber.error(error);
 			}
 			return i;
 		});