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

我有一个Web应用程序生成的业务事件数据库.

我想编写将接受这些事件(最多几百个)的
JavaScript应用程序,并使用复杂事件处理将在其中找到一些模式.

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

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

我看到RxJS有时间运算符,但看起来它正在使用当前时间.

更新1
我发现HistoricalScheduler类似乎是一个很好的方向,但没有关于它的文档,我不确定它是否存在于RxJS中.

最佳答案 检查rxmarbles示例代码.

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

根据我的理解,您应该能够适应您的用例

点赞