反应性框架（RX）和事件处理异步
所以，我只是在摆弄RX和学习它。我开始活动玩，并想知道如何订阅事件，以及异步处理结果的批次。请允许我用code解释： 简单的类引发的事件： 公共类EventRaisingClass { 公共事件的EventHandler＆LT; SomeEventArgs＆GT; EventOccured; //一些其他的code引发的事件...... } 公共类SomeEventArgs：E
..
system.reactive相关内容
我应该使用List＆LT; IObserver＆GT;或者干脆动作＆LT; T＆GT;跟踪一个的IObservable的订户的？
我实施的IObservable＆LT; T＆gt;在一些班级接口。我用反射弄清楚如何，这是通常的接收。关于如何可观察到的保持其用户的轨迹，并通过他们的 OnNext 方法通知他们，我偶然发现了与此类似code： 私人列表＆LT;观察＆LT; T＆GT;＆GT;观察员; //认购一个新的观察员： 公共IDisposable的订阅（IObserver＆LT; T＆GT;观察员） { obs
..
将反应扩展（接收）取代了任务并行库？
通过Rx.NET 的样本以下后，我采空区砸到如何辉煌的反应扩展的概念和实施是。这似乎为开发人员提供一个更易于维护的图案achiving同一类的多线程并行编码的.NET 4.0中的任务并行库提供。 将Rx.NET supercede第三方物流？它应该？ 解决方案 总之，没有。 任务并行库（TPL）规定提供作品的分布（并发），以及更大的工作的同时优化（并行），而抽象的实际机制工作分配（线程）。
..
当使用的IEnumerable VS的IObservable？
如何建立一个方法是否应该返回的IEnumerable＆LT; T＆GT; 或的IObservable＆LT; T＆GT; ？ 为什么我会选择一种模式比其他？ 解决方案 类型 的IEnumerable＆LT; T＆GT; 您重复地从 T 的序列“拉” 的IObservable＆LT; T＆GT; T 的的序列被“推”你 为什么我会选择一种模式比其他？ 您通常的不的“选择”一模式比
..
如何阅读交错文件同时使用无扩展
我是新来的反应扩展和我想用它（在C＃）来读取其中包含了几个交错流的文件。基本上，文件的格式为 ABCDABCDABCD ... 。我想preFER读取顺序文件，以及单独的数据流（即 AAA .. ， BBB .. 等），以及并行地处理每个流，使用单独的线程对每个流 有将必须是某种形式的缓冲，以使确保每个流可以保持忙碌尽可能（内当然限制）。不是所有的数据流开始的同时必须的，在这种情况下，一些元件具
..
单元测试FromAsyncPattern
在无扩展有一个性感的小钩，以简化异步调用方法： VAR FUNC = Observable.FromAsyncPattern＆LT;输入法菜单，OutType＆GT;（ myWcfService.BeginDoStuff， myWcfService.EndDoStuff）; FUNC（INDATA）.ObserveOnDispatcher（）订阅（X =＆GT;美孚（x）的）
..
后处置无接收2.0 EventLoopScheduler的ObjectDisposedException
我使用的是接收2.0的EventLoopScheduler排队/序列化的工作。当我需要处置调度，如果有剩余的工作，我会收到未处理的ObjectDisposedException。这是预期的行为？ 做作/样品code： EventLoopScheduler调度=新EventLoopScheduler（）; 名单＆LT; IDisposable的＆GT;处理=新的名单，其中，IDispo
..
使用无功扩展处理以正确的顺序多个响应
状况 我有一个，其中一个请求产生了两个响应系统。请求和响应都有相应的观测值： 的IObservable＆LT; RequestSent＆GT; _要求; 的IObservable＆LT; MainResponseReceived＆GT; _mainResponses; 的IObservable＆LT; SecondResponseReceived＆GT; _secondaryResponses
..
为什么Observable.Generate（）抛出System.StackOverflowException？
I'm编写C＃（.NET 4.5）用于聚合基于时间的事件进行报告的应用程序。为了使我的查询逻辑可重复使用的两种实时数据和历史数据我利用无扩展名（2.0）及其 IScheduler 基础设施（对 HistoricalScheduler 和朋友）。 例如，假设我们创建的事件列表（按时间顺序进行排序，但他们可能一致！），其唯一的有效载荷IST的时间戳，想知道他们在整个固定期限的缓冲区分配： const
..
反应性扩展基于特定数目的并行处理
我是新来的无功扩展。我有对象采集和调用一个方法为每个对象和方法返回布尔。相反，通过每个使用每个回路并调用方法循环的，有没有办法无扩展可同时调用（fork和join）方法的对象（例如5在一个给定的数字时间）后第一个完成，6应该调用方法，它应该继续下去，直到所有的对象都做了。 我AP preciate你的回应。 解决方案 的IObservable＆LT;布尔＆GT; someBoolAsyncM
..
什么是结构化的最佳途径这一LINQ到活动拖放放大器;删除code？
我想处理一个拖放放大器;下降的相互作用，它涉及按下鼠标，鼠标移动和鼠标了。 下面是我的解决方案的简化摄制的： 在按下鼠标，创建一个椭圆形，并把它添加到画布 在鼠标移动，重新定位椭圆跟随鼠标 在鼠标向上，改变了画布的颜色，这样很明显哪一个你拖动。 VAR MOUSEDOWN = Observable.FromEvent＆LT; MouseButtonEventArgs＆GT;（画布“的Mo
..
搜索上框TextChanged与无功扩展
我是想实现一个数据库表即时搜索用10000+记录。 搜索开始的时候里面的搜索文本框中的文本更改，当搜索框为空我想调用不同的方法加载的所有数据。 此外，如果用户改变，而正在加载结果其他搜索搜索字符串时，这些结果则装载应停止支持新的搜索。 我实现它像下面code，但我不知道是否有更好或更清洁的方式使用接收（无扩展名），运营商这样做，我觉得创建第二个观察到的内部认购的方法首先观察到的是比声明更为迫
..
做什么用的布置IObservers？
我使用的是无扩展，便于事件处理在我的ViewModels（Silverlight和/或WP7应用程序）。为简单起见，假设我有一个这样的线在我的虚拟机的构造函数： Observable.FromEvent＆LT; PropertyChangedEventArgs＆GT;（ H =＆GT; MyObject.PropertyChanged +
..
许多选择在接收
请任何一个让我知道如何在运营商的SelectMany的接收工作。我不知道更多关于这个运营商在LINQ to。请任何一个解释这一个简单的例子的帮助下，以及在什么场合，我们将在接收使用该操作符。在此先感谢 解决方案 的SelectMany 结合了投影和压扁成一个单一的步骤。假设你有一个数字表像 {{1,2}，{3，4，5}，{6,7}} 您可以使用的SelectMany 将其压扁成一个单一的列表，
..
是什么在所有这些反应观测扩展的实际差别？
给定一个BehaviorSubject，什么叫所有这些不同的功能上的实际差别？ 在第一个（） 在最后（） LatestValue（） MostRecentValue（） NextValue（） 在单（） 拍摄（1） 假设我的理解是正确的，他们都应该做同样的事情，考虑到BehaviorSubject。 如果是这样，那么它的呼叫是最合适的（我指的是：最能传达我的意图）？首先还是单身吧？ 如果不
..
异步队列处理与活性扩展
有一对夫妇在这个文章，我有这个工作......但我想知道如何设置工作线程我观测订阅的最大数量的一次。 我有以下并行异步保存日志条目： 私人BlockingCollection＆LT; ILogEntry＆GT; logEntryQueue; 和 logEntryQueue =新BlockingCollection＆LT; ILogEntry＆GT;（）; logEntryQueu
..
TPL VS无框架
当总会有选择使用接收了第三方物流或者是2框架正交？ 据我了解接收的主要目的是提供一个抽象过的事件，并允许成分，但它也可以提供一个抽象了异步操作。 通过配置了IDisposable返回使用Createxx重载和Fromxxx过载和取消。 TPL还提供了操作的抽象，通过任务和取消的能力。 我的困境是，当要使用的和什么情况下？ 解决方案 RX的主要目的不是提供一个抽象过的事件。这仅仅是它的成果
..
.NET接收的优势超过传统比赛项目？
.NET 4.0 Beta 2的有IObserver 接口。 有哪些优势比较经典的.NET事件？这是否解决同样的问题？ 解决方案 您可以使用的IObservable作为一个事件，替换code暴露类型的IObservable的性能事件，但这不是真正的点。 有了解有关的IObservable两个重要的事情： 它统一两个概念，我们不知道如何统一之前：异步操作（通常返回一个值）和事件（通常永
..
接收的真实世界的例子
可能重复： 良好的反应扩展使用的例子 我一直在玩与周围的反应延长了一小会儿了，但大多局限于处理/在一个WPF前端组成的用户驱动的事件。 这是做异步编程的这样一个强大的，新的方式，我很好奇，别人都在做它，并在你认为它可能是能够改善我们目前正在做的事情的方式呢？ 解决方案 我们使用RX上两个项目（Silverlight的用户界面）已经取得巨大成功 。在开始的意图是为了没想到，我们知道RX就像
..
从timetamps名单可观测
如果我有对象的列表，其中包含一个时间戳 - ？我怎样才能让一个可观察的那场大火事件的时间戳之间的相对时间 例如。如果我有三个对象时间戳2014年1月1日10：30，2014年1月1日10:45和2014年1月1日11点30分，我想第一个触发事件，向右走，然后在接下来的15分钟后，和最后一个45后分钟 我怎么能加快这一进程，使1分钟相当于1秒？因此，第一个事件将触发马上像以前一样，但未来会来15
..