手机建网站优帮云,怎么建设和聚享游一样的网站呢,分享影视资源的网站怎么做,神马网站可以做兼职何为Reactive Extensions#xff08;Rx#xff09;Rx是一个遵循函数式编程的类库#xff0c;它引用观察者以及迭代器设计模式对可观察对象产生的数据进行异步消费。使用Rx#xff0c;开发人员将使用LINQ运算符操作异步数据流#xff0c;并使用调度程序参数化异步数据流中的… 何为Reactive ExtensionsRxRx是一个遵循函数式编程的类库它引用观察者以及迭代器设计模式对可观察对象产生的数据进行异步消费。使用Rx开发人员将使用LINQ运算符操作异步数据流并使用调度程序参数化异步数据流中的并发性简单地说Rx Observables LINQ Schedulers。使用Rx需要Nuget安装System.Reactive Nuget包Rx的使用场景响应式UIUI界面上用户对一个绑定数据集合的控件进行关键字查询。常规的流程是我们必须在等待用户键盘按下指定的完成键(如回车)或鼠标点击查询按钮后程序才开始执行相应的查询处理。但假设需求变更“用户希望在每输入一个关键字后就能及时将关键字相应的查询结果集绑定到控件” 如果面临这个需求那你会如何实现呢 你会少不了定义相应的全局状态字段少不了相应的时间间隔刷新。我相信写出来的代码也会让你很烦恼。 其实你有更好的选择那就是我们的主角Rx。Rx 核心Rx有两个核心接口 IObservableT、IObserverTIObservableT先来看此接口的结构:IObservableT接口就提供一个Subscribe(订阅)方法入参是一个观察者对象接口。我们可以将IObservableT称之为被观察者(可观察者)IObserverT称之为观察者。通过可接口签名可以看出被观察者需要输出T类型的对象。需要理解被观察者IObservableT我们需要与现有的一些常规知识点做出比较这里我们用IEnumerableT比较。我想我们都使用过Linq操作过IEnumerableT集合IEnumerableT集合有个明显的状态就是它所存储的元素是静态的。集合内的元素状态除非代码显示的新增或删除、修改否则这个集合基本是静态(数据未变动)的。但是IObservableT则不同它的元素是根据被观察者提供的数据而变动的(不可预测的)就好比在UI上你无法预测用户的操作行为一样。下面这个表格可以看出两者区别IEnumerable可方便的列举集合元素值IObservable可观察对象变动的值IObserverTIObserverT接口可以理解为消费被贯彻着提供数据的一个接口它的三个方法决定了本次数据流的观察行为的走向。通俗理解就是被观察者生成数据观察者消费数据。来看下IObserverT的结构 OnNext 表示消费新数据OnError 表示观察数据流出现异常OnCompleted 表示明确关闭观察数据流代码示例下面代码定义了一个可观察的队列该队列会提供给观察者三个int类型的入参 1、2、3 供观察者对象的OnNext方法消费。 MyConsoleObserver(观察者)在得到数据后打印出来。通过示例代码我们得知了Rx.Net的数据流订阅、消费流程。SubjectT我们再来认识下SubjectTSubject是一个IObservable它以命令形式生成一个值并将该值推送给观察者对象。我们看下SubjectT的结构。 看这继承关系我们继续看SubjectBaseT里面有些啥~哎呀这个类真不得了啊把IObserverT和IObservableT都给继承了。这不是可以自己提供数据自己进行订阅和消费了么....我们来看看SubjectT是怎么玩的执行结果如下图需要注意的是订阅方法需要在数据生成前声明。总结好啦要睡觉啦基本上Rx核心的几个点就先讲到这我们也来总结下Rx.Net的几个核心知识点:可观察(被观察)对象生产数据观察者总是被动接收数据需要明确订阅后观察者才得以消费数据这里也只是自己的一个学习总结Rx也不是眼前的几个小示例就可以一目了然不过核心的知识基本上就是这些。至于还有一些操作符的话相信用过Linq的话上手不难难点在于需要在实际业务中找到合适的场景使用只有不断使用才会融会贯通。但是任何技术都不能滥用每一项新技术都有它最佳使用场景优秀的开发者需要做好权衡。原文地址:https://www.cnblogs.com/hunanzp/p/10325454.html.NET社区新闻深度好文欢迎访问公众号文章汇总 http://www.csharpkit.com
