以反应方式一次发送一个对象列表

Question

我正在通过一个带有对象的休息控制器方法接收一个请求，然后我将该对象传递给服务层中的一个方法。

此请求中的对象包含如下列表：

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()));
}

Answer 1

预期的方法是实际使用 fromIterable 方法并提供您的 List:

 return Flux.fromIterable(cartasRequest.getBalanceAlertServiceRequestData().getBalanceAlertList())
                .flatMap(prepaidClient::sendBalanceAlertData)
// convert to Mono again

以反应方式一次发送一个对象列表

Send a list of objects one at time in reactive way

spring

spring-boot

reactive-programming

spring-webflux

project-reactor