diff --git a/flyfish-web/src/main/resources/templates/ReactiveViewController.tpl b/flyfish-web/src/main/resources/templates/ReactiveViewController.tpl index 2305d1f..b10ce8d 100644 --- a/flyfish-web/src/main/resources/templates/ReactiveViewController.tpl +++ b/flyfish-web/src/main/resources/templates/ReactiveViewController.tpl @@ -13,6 +13,7 @@ import com.flyfish.framework.configuration.annotations.PagedQuery; import com.flyfish.framework.domain.base.Vo; import com.flyfish.framework.service.BaseReactiveService; import reactor.core.publisher.Mono; +import reactor.core.publisher.Flux; @RestController @RequestMapping("#{uri}") @@ -27,7 +28,7 @@ public class #{className} { return service.getPageList(qo) .map(Result::accept) .flatMap(result -> result.flatMap(list -> Flux.fromIterable(list) - .flatMap(item -> #{listViewClassName}().retrieve(item)) + .flatMap(item -> new #{listViewClassName}().retrieve(item)) .collectList())); } return service.getList(qo).flatMap(item -> new #{listViewClassName}().retrieve(item))