diff --git a/src/main/java/com/wabestway/recall/web/OrderController.java b/src/main/java/com/wabestway/recall/web/OrderController.java index cbe6fbe..27a030f 100644 --- a/src/main/java/com/wabestway/recall/web/OrderController.java +++ b/src/main/java/com/wabestway/recall/web/OrderController.java @@ -43,8 +43,10 @@ public class OrderController { Flux flux = orderRepository.findAll(ep, s).skip(pageRequest.getOffset()).limitRate(pageRequest.getPageSize()); OrderList resList = new OrderList(); Mono> listMono = flux.collectList(); - listMono.subscribe(list -> resList.setList(list)); - return Mono.just(ResObj.ok(resList)); + return listMono.flatMap(list -> { + resList.setList(list); + return Mono.just(ResObj.ok(resList)); + }); } @PostMapping("/info/{orderId}")