问题标签 [reactive-programming]

我最近在阅读有关游戏引擎设计的内容，最终偶然发现：什么是（功能性）反应式编程？

我想知道如何准确地实施第二高评分答案中给出的示例。在 C++ 中，将指针传递给存储鼠标坐标的值并返回它的值而不是 int 就很容易了。好吧，我们不能在 C# 中真正做到这一点，所以这是我们的第一个问题。我们是否需要调用一些“更新”函数来保持所有值都是最新的？

其次，如何处理语法？赋值是直截了当的。但是，像“每次我要求它时获取鼠标位置和 14 分钟”之类的事情稍微多一点..复杂..

最后，我想知道当你直接引用它时，如何让 C# 中的任何对象返回一个值。例如

test 会返回 1。所以我可以做 1 + test which would = 2 之类的事情

但如果我有一个实例

在尝试将 int 添加在一起时，我不能只做上面所做的事情。

对不起，我想这么广泛的问题。如果可以给出一个简单的示例来演示与该答案中讨论的功能相似的功能，我认为我的所有问题都会得到解答。

我收集了 INotifyPropertyChanged 对象，并希望将所有 PropertyChanged 事件流式传输到单个可观察序列中以进行进一步处理。

这是一个代码

由于某种原因，单个订阅在聚合序列中不起作用。看起来我聚合（使用 Reactive Extensions 的 Merge 功能）不正确。但是，在循环内订阅可以完美运行。

任何人都可以在这里帮助我，如何将多个事件流聚合为一个具有反应性扩展的事件流？

谢谢

我有

但我想要

并且我希望 observableTourn 的所有订阅者在任何底层可观察对象发生变化时触发？在 C# 中需要这个

我有以下 TPL 任务

在 Aggregate 方法实现中，我有许多 Observable.Subscription 以以下结尾

问题是保持任务活动和所有订阅活动而不旋转的最佳方法是什么？

我有以下产生 IObservable 问题的 Rx 查询，它不能与 Publish() 一起使用，因此随着订阅者数量的增加，内存负载也会增加

有没有更好的方法来创建这样的 Observable？

我正在尝试使用 RX 从 WCF 下载一些数据。但是Observable.FromAsyncPattern()结合使用时不返回任何响应SelecMany

我试图在下面的代码段中强调这个问题：

因此，如果SelecMany正确理解 RX，上面的代码应该打印：

“我在这里”

“不能到这里:(”

但是它只打印第一行而不是第二行

编辑：忘记提及此代码在没有附加调试器的情况下运行良好，但如果我在没有调试器的情况下运行它会失败

我正在学习在 winforms 中使用 Rx。当我使用此代码时，请告诉我如何更新我的进度条。

我一直在寻找有关如何在 rx 中使用 Observable.Buffer 的示例，但找不到比样板时间缓冲的东西更重要的东西。

似乎确实存在指定“bufferClosingSelector”的重载，但我无法理解它。

我要做的是创建一个按时间或“累积”缓冲的序列。考虑一个请求流，其中每个请求都有某种权重，我不想一次处理超过 x 个累积权重，或者如果累积的权重不够，就给我最后一个时间范围内的内容（常规缓冲区功能)

在我的应用程序中，我使用响应式扩展来发出 Web 请求。我的问题是，我提出两个请求。在第一个请求中，我将从服务器获取一个 url，并通过使用该 url 我发送另一个请求以获取图像和描述。在我的第一个请求中，除了 url，我将获得标题和日期相关信息。所以我正在做的是我将解析我的模型类中的数据，然后我将调用另一个请求。在这里，当我收到响应时，我会将其添加到可以保存结果的类对象中。当我的第一个请求的完整（onnext，error，complete）部分到达时，我将在我的财产中得到这两个结果。但问题是相应的更改，即第二个 Web 请求的结果没有反映在我的 UI 上。请任何人帮助我避免这个问题。

我一直在尝试使用带有以下内容的 tweetsharp 创建一个可观察的高音提要

但我只是无法让它工作有人能帮忙吗？