该应用程序使用 xstream 作为反应库。
我有一种奇怪的行为。
我的流就是这个图
在第一次会话 var update 我得到了这个调试结果：
问题：未执行“调试 2”分支
如果我更新会话项（以便产生新的存储事件），则两个分支都按预期执行
如果在“debug 0”处添加 .remember() 也会发生同样的良好行为
更奇怪的是，如果我移除过滤器，流程会按预期工作
没有过滤器（并且没有记住），自第一个事件以来，流程给出了这个结果
我的怀疑是在附加第二个分支之前在“调试 0”处观察到的东西，因此第一个事件已经被消耗。但是如果这两个分支是 xs.merged 在一起怎么会发生这种情况呢？如何执行一个分支而第二个不执行？这两个分支没有过滤器或其他处理，它们只是映射到一个 reducer 函数。关于如何调试和解决这种情况的任何建议？
问题的发生是因为它一被订阅就storage.session.getItem发出，并且在它订阅之前订阅，所以得到了事件，但是到订阅的时候，它已经来得太晚了。这个问题是众所周知的，被称为故障（在反应式编程中），通常在有菱形流图时发生，这正是您的情况。merge(a$, b$)a$b$a$b$
我有两篇关于故障的博客文章，它们可以为您提供更多背景信息：RxJS 调度程序入门和Rx 故障实际上不是问题。它提到了 RxJS，但 xstream 在实现方面非常接近 RxJS。xstream 和 RxJS 的区别在于 xstream 流总是多播（“共享”），而 RxJS 有很多调度器类型，但 xstream 只有一种。RxJS 中的默认调度程序与 xstream 具有相同的行为。
.remember()解决方案是在到达钻石之前申请。这是因为发出的值需要为该流的其他消费者缓存。.remember()只需将 Stream 转换为 MemoryStream。我认为源流最初是一个 MemoryStream，映射一个 MemoryStream 会创建其他 MemoryStream，但filter它是一个破坏它的运算符。filter总是返回一个 Stream，原因是 MemoryStreams 应该总是有一个当前值，但filter可以删除值，所以过滤后的流可能没有任何当前值。
作为 Cycle.js 的作者，我认为 cyclejs/storage 的设计方式并不是最好的，我认为我们会找到设计这些 API 的方法，以便尽量减少 MemoryStream 与 Stream 的混淆。但就目前而言，了解这两者之间的区别并规划您的应用程序以避免钻石（和故障）或.remember()在正确的位置使用是很重要的。