javascript - 使用 Bacon.js 去除唯一值

Question

我有一个文件系统观察器，它生成一个包含已更改文件路径的 Bacon.js 事件流。我想对该流进行过滤和反跳，以便每个唯一文件路径仅在该唯一值没有事件 5 秒后才出现在输出流中。我基本上想编写以下伪代码:

var outputStream = inputStream.groupBy('.path',
    function (groupedStream) { return groupedStream.debounce(5000); }
).merge();

我有一个复杂的解决方案，涉及为每个过滤流创建一个单独的 Bacon.Bus，并在每次遇到新的唯一值时创建一个新的总线。它们都经过去抖动并插入输出总线。有没有更好的办法？切换到 RxJS 并使用它的 groupBy 函数会更好吗？

Answer 1

原来 Bacon.js 最近添加了一个 groupBy 函数!我被表明它不存在的搜索误导了。所以这对我有用:

var outputStream = inputStream.groupBy(function (item) { return item.path; })
    .flatMap(function (groupedStream) { return groupedStream.debounce(5000); });

编辑:这是基于 OlliM 的评论(kiitos!)的简化版本:

var outputStream = inputStream.groupBy('.path')
    .flatMap(function (groupedStream) { return groupedStream.debounce(5000); });