From d7a64966489dd43aa29e306d7b686b5bbe5b029d Mon Sep 17 00:00:00 2001
From: liyuchang <648821884@qq.com>
Date: Wed, 17 Apr 2019 10:48:08 +0800
Subject: [PATCH] =?UTF-8?q?CityHandler.deleteCity=E6=96=B9=E6=B3=95BUG?=
 =?UTF-8?q?=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/org/spring/springboot/handler/CityHandler.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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<Long> 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)));
     }
 }