我通過一個帶有物件的 rest 控制器方法接收請求，然后我將其傳遞給服務層中的一個方法。
此請求中的物件包含一個串列，如下所示：
public class BalanceAlertServiceRequestData extends AlertServiceRequestData {
private List<BalanceAlertAttribute> balanceAlertList;
不是像我在其他方法中所做的那樣，在 Mono 中一次發送整個串列，在這種情況下，需要一次發送一個串列項。
下面是代碼注釋中有問題的方法：
public Mono<AlertServiceResponse> sendBalanceAlertDataToPrepaid(BalanceAlertServiceRequest cartasRequest) {
return Mono.just(cartasRequest.getBalanceAlertServiceRequestData().getBalanceAlertList())
// what goes here to read off each element, transform it, and then send it of as a single element in a Mono?
// Would it be something like "doOnEach(mapBalanceAlertServiceRequestToBalanceChangeAlertResponse)?"
.flatMap(prepaidClient::sendBalanceAlertData)
.thenReturn(cartaResponse(cartasRequest.getServiceRequestId()));
}
uj5u.com熱心網友回復：
預期的方法是實際使用該fromIterable方法并提供您的List：
return Flux.fromIterable(cartasRequest.getBalanceAlertServiceRequestData().getBalanceAlertList())
.flatMap(prepaidClient::sendBalanceAlertData)
// convert to Mono again
轉載請註明出處，本文鏈接：https://www.uj5u.com/yidong/326749.html
標籤：春天 弹簧靴 反应式编程 弹簧-webflux 项目反应堆