diff --git a/springboot-webflux-3-mongodb/src/main/java/org/spring/springboot/handler/CityHandler.java b/springboot-webflux-3-mongodb/src/main/java/org/spring/springboot/handler/CityHandler.java index 096ceb8..f52f7cf 100644 --- a/springboot-webflux-3-mongodb/src/main/java/org/spring/springboot/handler/CityHandler.java +++ b/springboot-webflux-3-mongodb/src/main/java/org/spring/springboot/handler/CityHandler.java @@ -37,7 +37,6 @@ public class CityHandler { } public Mono deleteCity(Long id) { - cityRepository.deleteById(id); - return Mono.create(cityMonoSink -> cityMonoSink.success(id)); + return cityRepository.deleteById(id).flatMap(mono -> Mono.create(cityMonoSink -> cityMonoSink.success(id))); } }