如何获取一个Flux中没有出现在另一个Flux中的元素

Question

我是Spring Reactive Project的新手。使用中出现问题。我有两个Flux，一个有更多元素，例如

Flux<Integer> bigFlux = Flux.range(1, 10);

还有人喜欢

Flux<Integer> smallFlux = Flux.just(3, 7);

如何获取bigFlux中未出现在smallFlux中的元素？我不知道该用哪个接线员。

我尝试过：

Flux<Integer> flux = bigFlux.filterWhen(one -> smallFlux.hasElement(one).map(a->!a));

但这并不明智，我通过复杂的操作获得了smallFlux，例如查询数据库、平面图操作。这样，bigFlux中有多少元素，这些操作将重复多少次。

事实上，小通量是通过这种方式获得的。

Flux<File> usedFile = repository.findAll()
                .flatMap(one -> {
                    List<File> used = someMethods(one);
                    return Flux.fromIterable(used);
                });

还有其他更好的解决方案吗，谢谢。

Answer 1

我认为这将是一个更干净、更快的解决方案

final Flux<Integer> bigListFlux = Flux.just(1, 2, 3);

final Flux<Integer> smallListFlux = Flux.just(3, 5, 6);

Mono.zip(bigListFlux.collectList(), smallListFlux.collectList(), (bigList, smallList) -> {

  bigList.removeAll(smallList);

  return bigList;
}).flatMapMany(Flux::fromIterable).map(element -> {

  System.out.println("element = " + element);

  return element;
}).subscribe(); // do not use subscribe/block in actual production code.

我使用了以下单声道的变体。邮政编码

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Mono.html#zip-Reactor。果心出版商单核Reactor。果心出版商Mono java。util。作用双功能-