Spring WebFlux flatmap返回单字

Question

我有一个用Kotlin写的WebApplication。这是一种有点不和的聊天。我有一个函数，它做几件事。该函数本身用于删除用户的帐户，但是在这样做的同时，它也删除了他从数据库中注销的消息，他将从数据库中的所有组中删除，在他是管理员的组中选择一个新的管理员。

而这个函数看起来确实是这样的：

fun deleteAccount(userId: String) : Flux<Void>{
        return groupRepository.findAllByAdmin(userId)
                .flatMap{
                    if(it.users.size<1) groupRepository.deleteById(it._id)
                    it.admin = it.users[0]
                    it.users.remove(userId)
                    groupRepository.save(it)
                }
                .flatMap {
                    messageRepository.deleteMessageByUserId(userId)
                    userRepository.deleteById(userId)
                }

    } 

我的存储库如下所示：

@Repository
interface GroupRepository : ReactiveCrudRepository<GroupRequest, String> {

    fun findByName(name: String): Mono<GroupRequest>
    fun existsByName(name: String): Mono<Boolean>
    fun findAllByAdmin(admin:String) : Flux<GroupRequest>

}

@Repository
interface MessageRepository : ReactiveCrudRepository<Message, String> {

    fun findMessageByGroupId(groupId: String): Flux<Message>
    fun deleteMessageByUserId(userId:String) : Mono<Void>
}

所以我的函数中的最后2个语句返回一个空单声道。问题是先执行哪条语句并不重要，只执行了两条语句中的一条，我现在尝试了几种方法，包括flux.zip，但它并不完全有效。如果我把deleteMessages放在第一位，除了数据库中删除用户的部分外，所有内容都可以工作。这个函数的问题在哪里，我该如何修复它？

Answer 1

我通过压缩第二个flatMap中的两个语句来修复它，如下所示：

fun deleteAccount(userId: String) : Flux<Void>{
        return groupRepository.findAllByAdmin(userId)
                .flatMap{
                    if(it.users.size<1) groupRepository.deleteById(it._id)
                    it.admin = it.users[0]
                    it.users.remove(userId)
                    groupRepository.save(it)
                }
                .flatMap {
                    Mono.zip(messageRepository.deleteMessageByUserId(userId),userRepository.deleteById(userId)).map {
                        it.t1
                    }
                }

    }