使用Rx编写GetMessages函数的最简洁方式是什么：static void Main() { Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); ...

使用 Rx 的 Subject，从多个线程调用 OnNext() 是线程安全的吗？ 因此，这个序列可以从多个来源生成。 merge 会做同样的事情吗？

我有一段生成大量网络和磁盘I/O的C# 5.0代码，需要并行运行多个副本。以下哪种技术可能会给我最好的性能： 使用await的async方法 直接使用TPL中的Task TPL Dataflow nuget 响应式扩展 我对这个并行化的东西不是很擅长，但如果使用像Thread这样的低级...

我正在寻找关于System.Reactive.Joins的介绍和文档，其中包括Pattern、Plan、QueryablePattern和QueryablePlan类。在Google上没有任何结果（"System.Reactive.Joins"），MSDN上也没有相关内容，这里没有示例可用，而...

我正在寻找一个能够对一系列事件进行防抖处理的运算符，比如用户点击。其输入和输出应该像这样：interval : -> <- -> <- in : 1--2--3-------4--5--5--6-7-8----...

我所做的只是实现观察者模式。 因此，我想出了这个解决方案： 我们有一个名为 PoliceHeadQuarters 的类，其主要工作是向所有订阅它的人发送通知。考虑到 DSP、Inspector 和 SubInspector 类都订阅了 PoliceHeadQuarters。 我使用事件和...

经过数天的谷歌搜索，我认为我不能决定哪一个框架适用于哪种场景。当然我想使用一个完美的框架将两者结合起来（这是不现实的）。我甚至知道它们可以一起使用，但真正的问题是每个框架中的哪些核心设计元素使得它们不可能互相模拟。 以下是我找到的： 在RX中，有虚拟时间，因此调度程序有效地控制整个网络，...

我和我的同事有分歧。我们正在编写一个处理海量数据的.NET应用程序。它接收数据元素，根据某些标准将子集组合成块并处理这些块。 假设我们有类型为Foo的数据项从某个源（例如从网络）逐个到达。我们希望收集相关的子集，构造每个这样的子集的Bar对象并处理Bar对象。 我们中的一位提议了以下设计。...

System.Reactive extension for .NET和新的C# 5.0(.NET 4.5) async/await都追求（或基于）future and promises constructs范式（方法）。 能否给出最简单的C#代码示例，说明它们之间的区别？ 是否可以在没...

我有一个热可观察对象，通常使用普通的Subject进行实现，以便那些感兴趣的人可以订阅实时通知流。 现在我想保留这个实时流，同时还暴露一个历史事件流，并附加绝对时间以了解它们发生的确切时间，并允许订阅者在重放时间线之前将历史流提前到任何时间点。 我认为大部分可以通过使用Historica...