英文:
Webflux : Accumulate & details
问题
I'm new to webflux and I'm trying to transform this code:
@Getterpublic class Stock {private int value;private String productNumber;public Stock(int value, String productNumber){this.value = value;this.productNumber = productNumber;}}@Getterpublic class StockResponse {private int value;private String productNumber;public StockResponse(int value, String productNumber){this.value = value;this.productNumber = productNumber;}public StockResponse(Stock stock){this.value = stock.getValue();this.productNumber = stock.getProductNumber();}public void add(int value){this.value += value;}}public List<StockResponse> findStockResponsesDetailsAndTotal() {List<StockResponse> stocksResponses = new ArrayList();List<Stock> stocks = stockRepository.findAll();StockResponse total = new StockResponse(0, "Total");stocks.forEach(stock -> {total.add(stock.getValue());stocksResponses.add(new StockResponse(stock));});stocksResponses.add(total);return stocksResponses;}
into a "flux philosophy"
Here is my code so far:
stockRepository.findAll().map(StockResponse::convert)
I'm kinda lost about the "total", I know that I can do a reduce on the Flux but i'll lose all the details in doing so.
英文:
I'm new to webflux and I'm trying to transform this code :
@Getterpublic class Stock {private int value;private String productNumber;public Stock(int value, String productNumber){this.value = value;this.productNumber = productNumber;}}@Getterpublic class StockResponse {private int value;private String productNumber;public StockResponse(int value, String productNumber){this.value = value;this.productNumber = productNumber;}public StockResponse(Stock stock){this.value = stock.getValue();this.productNumber = stock.getProductNumber();}public void add(int value){this.value += value;}}public List<StockResponse> findStockResponsesDetailsAndTotal() {List<StockResponse> stocksResponses = new ArrayList();List<Stock> stocks = stockRepository.findAll();StockResponse total = new StockResponse(0, "Total");stocks.forEach(stock -> {total.add(stock.getValue());stocksResponses.add(new StockResponse(stock));});stocksResponses.add(total);return stocksResponses;}
into a "flux phylosophy"
Here is my code so far :
stockRepository.findAll().map(StockResponse::convert)
I'm kinda lost about the "total", I know that I can do a reduce on the Flux but i'll lose all the details in doing so
答案1
得分: 1
I find it a bit odd to add the total result as the last element in the list instead of having a dedicated class containing the total on one side and the elements on the other).
But here's a code snippet anyway:
Mono<List<StockResponse>> responses = findAll().map(StockResponse::new).collectList().map(allStock -> {StockResponse total = new StockResponse(0, "Total");allStock.forEach(stock -> total.add(stock.value));List<StockResponse> result = new ArrayList<>(allStock);result.add(total);return result;});
英文:
I find it a bit odd to add the total result as the last element in the list instead of having a dedicated class containing the total on one side and the elements on the other).
But here's a code snippet anyway:
Mono<List<StockResponse>> responses = findAll().map(StockResponse::new).collectList().map(allStock -> {StockResponse total = new StockResponse(0, "Total");allStock.forEach(stock -> total.add(stock.value));List<StockResponse> result = new ArrayList<>(allStock);result.add(total);return result;});
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论