Java WebFlux/Reactor - 使用仅在 Mono<Set<String>> 中找到的项目过滤 Flux<List<String>>

Question

我是 WebFlux/Reactor 的新手，无法理解如何编写这段代码。基本上，我有一个 Flux，它有一个嵌套的 List foo 和一个 Mono bar，我只想返回 foo 中包含在 bar 中的项目。

// these two lines are representations of what the data looks like
Flux<CategoryModel> foo = { Permissions = [ "UserRole1"] } // List<String>
Mono<Set<String>> bar = [ "UserRole1", "UserRole2" ]; 

var filteredFoo = foo.filter(m -> m.getPermissions().stream().anyMatch(perm -> bar.block().contains(foo)));

上面代码块的问题是 contains() 上的 .block() 而我不想阻塞。不确定如何将其更改为非阻塞但仍检查栏是否包含永久项。

Answer 1

要直接回答问题 - 不要使用 filter()，使用 filterWhen()，它根据发布者而不是设置值进行过滤:

foo.filterWhen(m -> bar.map(set -> m.getPermissions().stream().anyMatch(perm -> set.contains(foo))));

请注意，您编写的代码有点奇怪，我只是直接翻译了它 - 但由于以下几个原因，目前它没有多大意义:

• 您正在传输权限，但目前并未在您的 anyMatch() lambda 中实际使用权限 - 因此目前您的代码可以简化为:

  foo.filterWhen(m -> bar.map(set -> set.contains(foo)));
  

• 即使给出上述情况，您仍在检查您的集合是否包含 foo，这是通量本身，因此没有合理的情况可以证明这是真的。