diff --git a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CachingRouteDefinitionLocator.java b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CachingRouteDefinitionLocator.java
index ef3bb0de..e1eef815 100644
--- a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CachingRouteDefinitionLocator.java
+++ b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CachingRouteDefinitionLocator.java
@@ -68,7 +68,7 @@ public class CachingRouteDefinitionLocator
 	@Override
 	public void onApplicationEvent(RefreshRoutesEvent event) {
 		fetch().materialize().collect(Collectors.toList())
-				.map(routes -> cache.put(CACHE_KEY, routes)).subscribe();
+				.doOnNext(routes -> cache.put(CACHE_KEY, routes)).subscribe();
 	}
 
 	@Deprecated
diff --git a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CachingRouteLocator.java b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CachingRouteLocator.java
index ad1272af..f5c8d636 100644
--- a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CachingRouteLocator.java
+++ b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CachingRouteLocator.java
@@ -70,7 +70,7 @@ public class CachingRouteLocator
 	@Override
 	public void onApplicationEvent(RefreshRoutesEvent event) {
 		fetch().materialize().collect(Collectors.toList())
-				.map(routes -> cache.put(CACHE_KEY, routes)).subscribe();
+				.doOnNext(routes -> cache.put(CACHE_KEY, routes)).subscribe();
 	}
 
 	@Deprecated