3

我正在扫描目录中的文件，然后处理结果。我想在进一步处理之前从数据存储中已有的扫描结果中删除文件。

尝试使用响应式 mongodb 以响应式方式执行此操作。我只是不确定如何以使用数据库查询结果的方式实现过滤器。

@Override
public Flux<File> findFiles(Directory directory) {

    // Only get these file types as we can't process anything else
    final Predicate<Path> extensions = path ->
            path.toString().endsWith(".txt") ||
                    path.toString().endsWith(".doc") ||
                    path.toString().endsWith(".pdf");

    final Set<File> files = fileService.findAll(Paths.get(directory.getPath()), extensions);

    final Stream<Video> fileStream = files
            .stream()
            .map(this::convertFileToDocument)

            // This is wrong (doesn't compile for a start), but how do I do something similar or of this nature? 
            .filter(file -> fileRepository.findById(file.getId()));

    return Flux.fromStream(fileStream);
}

convertFileToDocument只是将文件映射到 POJO，那里没有发生任何有趣的事情。

如何根据 的结果添加过滤器findById，或者有更好的方法来实现这一点？

4

1 回答 1

3

如果fileRepository.findById返回 Mono，我建议您将流转换为通量，然后使用过滤filterWhen；检查 Mono 是否有元素。就像是

final Stream<Video> fileStream = files
        .stream()
        .map(this::convertFileToDocument);
return Flux.fromStream(fileStream).filterWhen(file -> fileRepository.findById(file.getId()).hasElement().map(b -> !b));

这将过滤掉所有返回非空 Mono forfindById或存在于数据库中的文件。如果我误解了什么，请告诉我。

于 2019-01-28T05:29:53.260 回答