问题标签 [rx.net]

给定一个IObservable<T>使用Throttle行为的方法（在添加项目时重置计时器，但它是否返回在该时间内添加的所有项目的集合？

Buffer提供了一个类似的功能，它IList<T>在每个时间跨度或计数上将数据分块。但是每次添加项目时，我都需要时间来重置。

我在这里看到了一个类似的问题，反应式扩展是否支持滚动缓冲区？，但答案似乎并不理想，而且它有点旧，所以我想知道 Rx-Main 的发布版本现在是否支持这个功能。

我为响应式扩展创建了一个SlidingWindow操作符，因为我想轻松监控滚动平均值等内容。举个简单的例子，我想订阅听到鼠标事件，但每次有一个事件我想接收最后三个（而不是等待每第三个事件接收最后三个）。这就是为什么我发现的 Window 重载似乎没有给我开箱即用的东西。

这就是我想出的。鉴于其频繁的 List 操作，我担心它可能不是最高效的解决方案：

可以这样调用：

然而，令我大吃一惊的是，并没有收到预期的结果

我收到结果

任何见解将不胜感激！

我想在 Rx 订阅中回调一个异步函数。

比如这样：

为了正确捕获异常，需要做什么？

我正在使用 RX，我想将源流绑定/映射到目标流，以便可以动态更改源流而不影响对目标流的任何订阅。

我将在这里布置我的（天真的）解决方案，希望有人可以向我展示更好的解决方案。

我希望有现有的扩展方法可以组合来实现这个结果。如果不是，我希望制作一个自定义扩展方法来简化我的解决方案。

这是一个如何使用它的非常简单的示例：

我阅读了 Reactive Extension 的代码，然后我找到了这段代码

我发现方法SubscribeSafe(sink)在类ObservableExtensions中，而类没有实现接口IObservable。为什么参数_source有成员函数 SubscribeSafe()？

我想通过使用它的 UML 图更好地理解 Rx 代码。然后我使用VS2013社区来生成它。但它失败了。

与句子“集合已修改；枚举操作可能无法执行”发生对话。是什么原因？以及如何纠正？

我试图从这个视频中重建 Jonathan Worthington 的 Twitter 示例： https ://www.youtube.com/watch?v=_VdIQTtRkb8

它开始工作正常。但过了一会儿，溪流停止了。在输入的第三个搜索主题中，该应用不再收到任何推文。我不知道为什么。它似乎不依赖于时间。因为如果我让它运行而不更改搜索主题，它就会继续运行。任何人都可以帮忙吗？

这是主窗口的代码：

这是 XAML 代码：

这就是创建 IObservable 的方式：

最后是情绪分析：

如何清除 a 上的缓冲区ReplaySubject？

我需要定期清除缓冲区（在我的情况下作为一天结束的事件）以防止ReplaySubject不断增长并最终吃掉所有内存。

理想情况下，我希望保持不变ReplaySubject，因为客户订阅仍然很好。

我正在学习 .net Rx (Reactive Extensions) 库并尝试创建一个适当的 Observable 来从控制台读取用户输入。

到目前为止，我来到了这个：

不幸的是，这个实现至少有一个问题——没有办法取消订阅。

所以我的问题是：如何正确地将一系列阻塞事件转换为 Observable？

谢谢。

编辑：错别字

我的系统有很多状态对象——连接状态、cpu 负载、登录用户等等。所有这些事件都合并到一个可观察的流中。

我想制作一个管理实用程序来显示系统的实际状态并显示所有这些计数器。

如何创建一个包含所有计数器最后更改值列表的可观察对象？

这是我想要的大理石图：

所需的输出：

到目前为止，我可以实现：

这是一个使用示例：

还有转储功能（来自Lee Campbell的好书）：

所以问题是：有没有更好的方法来实现这个功能？可能不在可观察对象中使用字典？

谢谢你。