Spring Boot WebFlux 实现 Restful 服务，基于 HTTP / JSON 传输

Author: liqiangqiang

springboot-webflux-2-restful/src/main/java/org/spring/springboot/domain/City.java

@@ -3,7 +3,6 @@
 /**
  * 城市实体类
  *
- * Created by bysocket on 09/29/2017.
  */
 public class City {
 

springboot-webflux-2-restful/src/main/java/org/spring/springboot/handler/CityHandler.java

@@ -22,14 +22,11 @@ public Mono<Long> save(City city) {
     }
 
     public Mono<City> findCityById(Long id) {
-        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.findCityById(id)));
+        return Mono.justOrEmpty(cityRepository.findCityById(id));
     }
 
     public Flux<City> findAllCity() {
-        return Flux.create(cityFluxSink -> {
-            cityRepository.findAll().forEach(city -> cityFluxSink.next(city));
-            cityFluxSink.complete();
-        });
+        return Flux.fromIterable(cityRepository.findAll());
     }
 
     public Mono<Long> modifyCity(City city) {