Spring反应：操纵通量成单声道型响应

Question

我对Spring Reactive还是个新手。

我想将一个Spring反应式回购通量响应转换为另一种类型的单声道响应：

@Transactional(readOnly = true)
@Override
public Mono<BaseListResponseVm<AcsTransactionVm>> transactionsBy(
        @NonNull Integer offset,
        @NonNull Integer limit,
        @NonNull String term,
        AcsTransactionRequestDto dto
) {
    var response = new BaseListResponseVm<AcsTransactionVm>();
    var list = repository.findByPan(term, PageRequest.of(offset, limit));

    return repository.findByPan(term, PageRequest.of(offset, limit))
            XXXXX.(res -> {
                response.setItems(); // List<AcsTransactionVm>
                response.setCount(); // Long
            });
}

public interface AcsTransactionRepository extends ReactiveCassandraRepository<AcsTransactionDao, Integer> {

    @AllowFiltering
    Flux<AcsTransactionDao> findByPan(String term, Pageable page);

}

我已经尝试了提供的运算符（转换是我需要的闭包，但它仍然将repo结果的每一个参数都提供为reactive参数），但最终不能得到任何我知道如何使用的东西。

Answer 1

看来是这样做的：

@Transactional(readOnly = true)
@Override
public Mono<BaseListResponseVm<AcsTransactionVm>> transactionsBy(
        @NonNull Integer offset,
        @NonNull Integer limit,
        @NonNull String term,
        AcsTransactionRequestDto dto
) {
    log.debug("DB: fetching ACS transactions using offset {}, limit {}, term {} and request {}", offset, limit, term, dto);
    var response = new BaseListResponseVm<AcsTransactionVm>();

    return repository.findByPan(term, PageRequest.of(offset, limit))
            .collectList().map(transactions -> {
                var mappedItems = transactions.stream()
                        .map(mapper::toVm)
                        .collect(Collectors.toList());
                response.setItems(mappedItems);

                return response;
            });
}