问题标签 [mostjs]

我有许多具有循环依赖关系的流。

传递的函数用于.thru(...)获取流并应用一些运算符组合，例如.filter(), .map()，.until()但是，值得注意的是（请参见下文了解原因），.delay().

这些是我已经尝试过的事情：

方法一

这里的问题是您必须预先将流传递给采样，但streamC不能在streamAand之前声明streamB。

方法 2（或 1.1）

此方法建立在方法 1 的基础上，但只是代理可以使用most-subjectstreamC_proxy预先声明的事件。streamC

我认为这确实有效，但无法使用most-test 进行测试（它需要使用自己的调度程序，但.subscribe()/.observe()隐式使用defaultScheduler）。正如我所说，我使用.delay()并等待几秒钟/几分钟来运行测试 - 使用默认调度程序 - 是不可行的。

方法三

除了这段代码远非理想之外，它应该可以工作。但它没有:(

问题

这可以以可测试的方式完成吗？

我很好奇当前从可能不符合现有流创建方法的源创建流的最佳实践（https://github.com/cujojs/most/blob/master/docs/api.md）

使用 Firebase 的示例ref.on('child_added', function(snap){})：

我不能使用.fromEvent...虽然 ref 实现了某种on，但它似乎不符合 EventEmitter 接口（addEventListener、removeEventListener）

手动发出事件，是我目前能想到的最好的......

是否有类似的机制来自定义创建流，例如 la Rx？

我有没有更好的方法？

我有一个小组件，我想提供类似于此示例的属性类型

我正在使用带有 mostjs 流库的cyclejs。

这有效：

类型Sources只是：

我想为以下内容创建明确的类型CheckboxSources：

但是DOMSource使用Stream来自xstream--- 我需要在两个流库之间进行转换吗？我想most-run会把这种转换抽象掉吗？

我可以使用anyDOM 的类型，但更喜欢显式类型。

很明显，使用 和 两种方法的 xstreamaddListener能够removeListener动态地重新路由流（更改它们的源和接收器）。我看不到 mostjs 的等价物。大多数只让您布置一次流的路由吗？如果是这样，这种静态特性是否允许大多数 js 优化以获得如此卓越的性能？

此外，xstream 使用了一种imitate方法，使其具有循环依赖关系。有没有办法用mostjs实现循环依赖？

我正在使用 Motorcycle 创建一个小型应用程序。我需要在每个 requestAnimationFrame 上调用一个函数。由于它是一个副作用，我知道它必须在一个“有效”的组件中完成。但是，大多数 js 不提供源，例如它提供periodic()和now()来制作 requestAnimationFrame 流。如何在我的应用程序中实现这样的功能？