确保Spring WebFlow中的方法执行

Question

override fun uploadFileAndNotifyCadmium(
        validatedPages: List<KycFile>,
        documentId: UUID,
    ): Mono<Unit> {

        validatedPages.forEach { it ->
            s3Service.uploadToToxicBucket(
                documentId, it.fileName })
                .then()
        }

        return cadmiumClient.notifyCadmium(documentId) // API call to other microservice
    }

我有这个方法，我试图调用一个方法（s3Service.uploadToToxicBucket（）），它在迭代列表时返回单声道。我希望确保为每个列表元素调用此方法。因此，我在生成的Mono中添加了然后（）。此外，我希望方法cadmiumClient.notify镉（）仅在上传所有文件后执行。这是正确的方法吗？或者我可以使用其他操作符吗？。cadmiumClient.notify镉（）也返回单声道单位。

我还调用了uploadfileandnotify（）。然后（）。

我正在使用然后（），因为执行是懒惰的，并且我不想调用订阅（）来确保这些方法的执行。此外，控制器中还调用了方法上传文件和文件，因此它是由Spring网络流量自动订阅的。我对that（）用法的理解可能是错误的。

方法2：我也想过这样做：

override fun uploadFileAndNotifyCadmium(
        validatedPages: List<KycFile>,
        documentId: UUID,
    ): Mono<Unit> {

        val list = mutableListOf<Mono<Unit>>()

        validatedPages.forEach { it ->
            val result =s3Service.uploadToToxicBucket(
                documentId, it.fileName })

        list.add(result)

        }

        //Zip all the elements in list together into some variable zippedResult

        return zippedResult.then(cadmiumClient.notifyCadmium(documentId)) // API call to other microservice
    }

对于这种方法，当列表的大小以前未知时，我找不到任何操作符将所有元素压缩在一起。




Answer 1

我试图理解你想做什么，因为你的解释很不清楚。

我不使用Kotlin编写代码，但如果我做对了，您要做的是：

• 获取n个物体的列表
• 对列表中的每个对象执行某种类型的副作用
• 收集所有副作用的某种形式的结果
• 返回此结果

这就是我在简单的反应性java中的做法

    return Flux.fromIterable(List.of("one", "two", "three"))
            .flatMap( // do some side effect )
            .collect(Collectors.toList());

• 将列表转换为Flux