rxjs - 使用 RxJS 进行业务事件的复杂事件处理

Question

我有一个我们的 Web 应用程序生成的业务事件数据库。
我想编写 JavaScript 应用程序来处理这些事件(最多数百个)，并且使用复杂事件处理会在其中找到一些模式。

例如，如果我们在 15 分钟内有没有登录事件的登录失败事件，我们想知道它。我们使用 session ID 关联事件。

我更喜欢使用存在库，从我看到的 RxJS似乎是正确的工具。
我的问题是如何使用原始事件的时间戳而不是当前计算机时间来构建事件流？

我看到 RxJS 有时间运算符，但它看起来像是在使用当前时间。

更新 1
我找到了 HistoricalScheduler class 看起来是一个很好的方向，但没有关于它的文档，我不确定它是否存在于 RxJS 中。

Answer 1

检查 rxmarbles 示例代码。

特别是:https://github.com/staltz/rxmarbles/blob/master/src/controllers/utils.coffee它使用 Rx.VirtualTimeScheduler。

根据我的理解，您应该能够对其进行调整以适合您的用例