过滤带有从另一个通量的分机单元的通量

Question

我有两个来自ReactivemongoDB API的通量： 第一个将获取 date1 的数据 第二个获取 date2 的数据 到最后，我想排除从date2中仍出现的元素，以使那些消失的元素并将其保存在另一个集合中。 为了解决该问题，我使用标签来收集第二个日期的元素（Date2），因此我可以通过排除标签中的元素来过滤第一个日期（date2）的通量。

Flux<Report> reportOfCurrentDate = reportRepository.get(LocalDate.now());
Flux<Report> reportOfPrevDate = reportRepository.get(LocalDate.now().minusDays(1));

reportOfCurrentDate.log("insert In Set :").collect(Collectors.toSet());

// filtering 
reportOfPrevDate
.filterWhen(
                report -> resourceIds
                        .map(installedResId -> !installedResId.contains(report.getInstalledResInstalledResourceId()))
)
.transform(rereports -> resolvedRepository.insertAll(reports.collectList())
.blockLast();

请注意，通量正在使数据形成非常大的集合 问题是我只能在一个磁通量中（插入一组插入的磁通）似乎没有反应性的行为是预期的是，这两个通量将并行运行，过滤数据并最终插入新集合中。 有人可以帮助我，还是建议另一种做到这一点？