取决于单声道分辨率的通量

Question

我正在学习反应式编程和spring webflux，但我不知道依赖于Mono分辨率的Flux应该如何返回。

interface FooRepository : ReactiveMongoRepository<Foo,String> {
    fun findAllByCreatedBy(email: String): Flux<Foo>
}

fun getCurrentUser() = ReactiveSecurityContextHolder.getContext()
            .map { ctx -> ctx.authentication.principal }
            .cast(UsernamePasswordAuthenticationToken::class.java)
            .map(UsernamePasswordAuthenticationToken::getPrincipal)
            .cast(User::class.java)
            .map(User::email)

 fun list(): Flux<ResponseEntity<Foo>> {
        val fooes = findAllByCreatedBy(getCurrentUser()) // This not work because getCurrenUser() returns a Mono<String>
        return fooes.map { o -> ResponseEntity(o, HttpStatus.OK)
 }

如何等待getCurrentUser（）输出或将其与findAllByCreatedBy（）链接？

Answer 1

对于链接单声道和通量，您可以使用平面图运算符；

例如：

getCurrentUser()
 .flatMapMany(userEmail-> findAllByCreatedBy(userEmail))