diff --git a/build.gradle b/build.gradle
index 041c825314..f917e910c7 100644
--- a/build.gradle
+++ b/build.gradle
@@ -125,7 +125,7 @@ subprojects { subproject ->
 		pahoMqttClientVersion = '1.1.1'
 		postgresVersion = '42.0.0'
 		reactorNettyVersion = '0.6.3.RELEASE'
-		reactorVersion = '3.1.0.BUILD-SNAPSHOT'
+		reactorVersion = '3.1.0.M1'
 		romeToolsVersion = '1.7.2'
 		servletApiVersion = '3.1.0'
 		slf4jVersion = "1.7.25"
diff --git a/spring-integration-file/src/test/java/org/springframework/integration/file/dsl/FileTests.java b/spring-integration-file/src/test/java/org/springframework/integration/file/dsl/FileTests.java
index ceab398001..b8c5de9bab 100644
--- a/spring-integration-file/src/test/java/org/springframework/integration/file/dsl/FileTests.java
+++ b/spring-integration-file/src/test/java/org/springframework/integration/file/dsl/FileTests.java
@@ -65,9 +65,13 @@ import org.springframework.integration.dsl.IntegrationFlows;
 import org.springframework.integration.dsl.Pollers;
 import org.springframework.integration.dsl.StandardIntegrationFlow;
 import org.springframework.integration.dsl.channel.MessageChannels;
+import org.springframework.integration.expression.FunctionExpression;
 import org.springframework.integration.file.DefaultFileNameGenerator;
 import org.springframework.integration.file.FileHeaders;
 import org.springframework.integration.file.FileReadingMessageSource;
+import org.springframework.integration.file.filters.AcceptOnceFileListFilter;
+import org.springframework.integration.file.filters.ChainFileListFilter;
+import org.springframework.integration.file.filters.ExpressionFileListFilter;
 import org.springframework.integration.file.splitter.FileSplitter;
 import org.springframework.integration.file.support.FileExistsMode;
 import org.springframework.integration.file.tail.ApacheCommonsFileTailingMessageProducer;
@@ -395,7 +399,10 @@ public class FileTests {
 		public IntegrationFlow fileSplitterFlow() {
 			return IntegrationFlows
 					.from(Files.inboundAdapter(tmpDir.getRoot())
-									.filterFunction(f -> "foo.tmp".equals(f.getName())),
+									.filter(new ChainFileListFilter<File>()
+											.addFilter(new AcceptOnceFileListFilter<>())
+											.addFilter(new ExpressionFileListFilter<>(
+													new FunctionExpression<File>(f -> "foo.tmp".equals(f.getName()))))),
 							e -> e.poller(p -> p.fixedDelay(100)))
 					.split(Files.splitter()
 									.markers()