我通過一個帶有物件的 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/qiye/322706.html
標籤：春天 弹簧靴 反应式编程 弹簧-webflux 项目反应堆