问题标签 [reactive-programming]

I am playing with Rx in .Net3.5SP1 and trying the 101 Rx Samples. I am trying the first sample (Start - Run Code Asynchronously) but it doesn't seem to actually run asynchronously. For example,

Outputs

Is there an explanation for this? Am I doing something wrong? Is this expected behaviour?

UPDATE

I would have thought it would have said

But the main thread is blocked while the supposedly Asynch call happens.

我现在正在通过 FieldTrip 适配器学习 FRP。并以奇怪的帧调度和集成方式解决了这个问题。所以现在我正在尝试构建自己的标记事件来对齐行为步进。

所以...

问题是：

一直在搜索，但我发现的唯一东西是http://evain.net/blog/articles/2009/07/30/rebasing-system-reactive-to-the-net-clr我开始工作了，但感觉就像应该有一个更简单的方法，特别是因为 rx 是在 09 年中期首次发布。

在 IOI 编程竞赛中有时会看到响应式任务。与批处理任务不同，反应式解决方案从另一个程序获取输入并输出它。该程序通常“查询”法官程序一定次数，然后输出最终答案。

一个例子

客户端程序逐行接受，并简单地回显它。当它遇到带有“done”的行时，它立即存在。

Java 中的客户端程序如下所示：

判断程序提供输入并处理来自客户端程序的输出。在这个例子中，它向它提供一个预定义的输入，并检查客户端程序是否正确地回显了它。

一个会话可能是这样的：

我在编写判断程序并让它判断客户端程序时遇到问题。如果有人可以为我的示例编写一个判断程序，我将不胜感激。

有人可以解释 Observable 和 ConnectableObservable 之间的区别吗？Rx Extensions 文档非常稀少，我不明白 ConnectableObservable 在什么情况下有用。

此类用于重播/修剪方法。

我对 Rx 还是很陌生，很难弄清楚如何表达这个（看似）简单的订阅。我正在寻找这样的东西：

1. 开始： InTransaction.Where(inTransaction => inTransaction)
2. 如果：ItemChanged 或 On FlagChanged，让 Changed = true
3. 结束： InTransaction.Where(inTransaction => !inTransaction)

以上都是可观察的。因此，在交易开始时，我想开始关注更改通知，无论有多少进来，我只想记住已经收到任何通知。当事务结束时，我想调用我的处理程序来更新视觉状态。

网上有很多有趣的例子展示了如何为鼠标拖动执行此操作。我遇到的唯一问题是我不想获得每一个更改的事件。我想知道在交易结束之前是否有任何被击中。

谁能帮我指出正确的轨道？

更新：我当前的算法看起来像这样：

工作正常，但我想知道我是否可以通过一次订阅来摆脱困境。

使用 Rx，有没有一种简单的方法来创建一个单一的Notification<T>？

我能找到的最接近的是：

这似乎相当迂回。的构造函数Notification<T>无法访问，但是有没有我不知道的工厂方法？

我安装了 VS2010 RTM，我想添加对 Reactive Framework 的引用，我已经寻找 system.CoreEx 和 system.Reactive 并且它们不存在。我究竟做错了什么？

这是一个介绍反应式框架的简单程序。但我想尝试错误处理程序，将程序修改为：

在此示例中，使用了以下重载。

我希望我会看到打印的异常消息，但是控制台应用程序崩溃了。是什么原因？

反应式编程 和pi 演算有共同点吗？