diff --git a/pom.xml b/pom.xml
index bf79c3d24..077eec9ab 100644
--- a/pom.xml
+++ b/pom.xml
@@ -23,7 +23,7 @@
 	</scm>
 	<properties>
 		<java.version>1.8</java.version>
-		<reactor.version>Dysprosium-SR6</reactor.version>
+		<reactor.version>2020.0.0-M1</reactor.version>
 		<objenesis.version>2.1</objenesis.version>
 		<spring-cloud-function.version>3.1.0-SNAPSHOT</spring-cloud-function.version>
 		<maven-checkstyle-plugin.failsOnError>true</maven-checkstyle-plugin.failsOnError>
diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
index 31122910f..739d62531 100644
--- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
+++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
@@ -246,7 +246,7 @@ public class FunctionConfiguration {
 			taskScheduler.schedule(() -> { }, Instant.now()); // will keep AC alive
 		}
 		else { // implies pollable
-			integrationFlowBuilder = IntegrationFlows.from(supplier);
+			integrationFlowBuilder = IntegrationFlows.fromSupplier(supplier);
 			if (splittable) {
 				integrationFlowBuilder = integrationFlowBuilder.split();
 			}
diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java
index b77c752d8..cf9fe2273 100644
--- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java
+++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java
@@ -379,7 +379,7 @@ public class SourceToFunctionsSupportTests {
 					.withPayload("hello function")
 					.setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.TEXT_PLAIN)
 					.build();
-			return IntegrationFlows.from(messageSource).channel(source.output()).get();
+			return IntegrationFlows.fromSupplier(messageSource).channel(source.output()).get();
 		}
 
 	}