C# Rx的主要接口深入理解

2024-04-14 15:00:38

C# Rx的主要接口深入理解

　IObservable / IObserver 接口在.NET Framework 4.0基类库中可用，并且它们包含在可以安装在.NET 3.5，Silverlight 3和4以及JavaScript中的包中。

IObservable/IObserver

　　Rx将异步和基于事件的数据源公开为基于推送的可观察序列，由.NET Framework 4.0中的新IObservable 接口抽象。这个IObservable 接口是用于基于拉的，可枚举集合的熟悉的IEnumerable 接口的双重。它表示可以观察到的数据源，这意味着它可以向任何有兴趣的人发送数据。它维护一个代表这种感兴趣的监听器的依赖IObserver 实现的列表，并且自动地通知它们任何状态变化。

　　IObservable 接口的实现可以被视为类型T的元素的集合。因此，IObservable 可以被视为整数的集合，其中整数将被推送到订阅的观察者

　　如“什么是Rx”中所述，推送模型的另一半由IObserver 接口表示，它表示通过订阅注册兴趣的观察者。随后将项目从其订阅的可观察序列递送给观察者。

　　为了从observable集合接收通知，您使用IObservable的Subscribe方法为其传递IObserver 对象。作为对此观察者的回报，Subscribe方法返回一个IDisposable对象，作为订阅的句柄。这允许您在完成后清理订阅。在此对象上调用Dispose将观察者从源分离，以便不再传递通知。正如你可以推断，在Rx中，不需要像.NET事件模型中那样显式取消订阅事件。

　　观察者支持三个发布事件，由接口的方法反映。当可观察的数据源具有可用的数据时，OnNext可以被调用零次或更多次。例如，用于鼠标移动事件的可观察数据源可以在每次鼠标移动时发出一个Point对象。其他两种方法用于指示完成或错误。

　　下面列出了IObservable / IObserver 接口。　　

public interface IObservable<out T>
{
  IDisposable Subscribe(IObserver<T> observer);
}
public interface IObserver<in T>
{
  void OnCompleted();// Notifies the observer that the source has finished sending messages.
  void OnError(Exception error); // Notifies the observer about any exception or error.
  void OnNext(T value);     // Pushes the next data value from the source to the observer.
}

　　Rx还提供了Subscribe扩展方法，以便您可以自己避免实现IObserver 接口。对于可观察序列的每个发布事件（OnNext，OnError，OnCompleted），可以指定将调用的委托，如下面的示例所示。如果不为事件指定操作，则将发生默认行为。

IObservable<int> source = Observable.Range(1, 5); //creates an observable sequence of 5 integers, starting from 1
IDisposable subscription = source.Subscribe(
              x => Console.WriteLine("OnNext: {0}", x), //prints out the value being pushed
              ex => Console.WriteLine("OnError: {0}", ex.Message),
              () => Console.WriteLine("OnCompleted"));

　　您可以将可观察序列（例如鼠标悬停事件的序列）看作是正常集合。因此，您可以在集合上编写LINQ查询以执行过滤，分组，合成等操作。为了使可观察序列更有用，Rx程序集提供了许多工厂LINQ运算符，因此您不需要自己实现任何这些。这将在使用LINQ运算符的查询可观察序列主题。　

警告：

您不需要自己实现IObservable / IObserver 接口。 Rx为您提供这些接口的内部实现，并通过Observable和Observer类型提供的各种扩展方法暴露它们。有关详细信息，请参阅创建和查询可观察序列主题

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

C# 基础入门--关键字

例子: using System; using System.Collections.Generic; using System.Text; namespace Test { class Program { static void Main(String[]args) { Console.WriteLine("Hello World!"); } } } 1．关键字 class ,这个关键字的用途是声明类,是C#程序最小单元,比如上面例子中,类名叫做Program. 2．关键字 name
C#中partial关键字的作用

1. 什么是局部类型? C# 2.0 引入了局部类型的概念.局部类型允许我们将一个类.结构或接口分成几个部分,分别实现在几个不同的.cs文件中. 局部类型适用于以下情况: (1) 类型特别大,不宜放在一个文件中实现. (2) 一个类型中的一部分代码为自动化工具生成的代码,不宜与我们自己编写的代码混合在一起. (3) 需要多人合作编写一个类. 局部类型是一个纯语言层的编译处理,不影响任何执行机制--事实上C#编译器在编译的时候仍会将各个部分的局部类型合并成一个完整的类. public partia
C# 基础入门--变量

使用变量分为3步:声明.赋值.使用. 声明变量的语法:数据类型变量名: 给变量赋值的语法:变量名=值: namespace Test { class Program { static void Main(string[] args) { int age;//声明变量,类型为int,变量名为age age = 18;//给变量age赋值为18 Console.WriteLine("我今年"+age="岁");//打印age age = 19;//修改了变量age的值
C# 基础入门--注释

注释,是代码中的一些"说明性文字".注释本身不会参与程序的编译和运行,仅仅供程序员阅读. 注释分为:单行注释.多行注释.文档注释. 单行注释的符号是2条斜线"//",2条斜线右侧的内容就是注释,左侧的代码不会受影响. 多行注释以"/*"开始,以"*/"结束,之间的内容就是注释,可以包含多行. 文档注释写在类.方法或属性的前面,它的符号是3条斜线"///". namespace Test { /// <
c#消息提示框messagebox的详解及使用

C#消息提示框messagebox的详解及使用消息对话框是用messagebox对象的show方法显示的.MessageBox对象是命名空间System.Windows.Forms的一部分,Show是一个静态方法,意思是说,不需要基于MessageBox类的对象创建实例,就可以使用该方法.而且该方法是可以重载的,即方法可以有不同的参数列表形式. 返回结果:DialogResult dr1=MessageBox.Show(text,caption,buttons,icon,defaultbutt
C#中new的几种用法详解

在 C# 中,new 关键字可用作运算符.修饰符或约束. new 运算符用于创建对象和调用构造函数. new 修饰符用于向基类成员隐藏继承成员. new 约束用于在泛型声明中约束可能用作类型参数的参数的类型. new 修饰符(C# 参考) 在用作修饰符时,new 关键字可以显式隐藏从基类继承的成员.隐藏继承的成员意味着该成员的派生版本将替换基类版本.在不使用 new 修饰符的情况下隐藏成员是允许的,但会生成警告.使用 new 显式隐藏成员会取消此警告,并记录代之以派生版本这一事实. 若要隐
C# 基础入门--常量

常量,顾名思义,就是"不会改变的量". 我们平时书写的数字(比如12.85).字符(比如'F').字符串(比如"谢谢"),它们都属于"字面常量". 有一些常量既重要又容易出错,比如圆周率π的值为3.1415926......,所以,我们常常会使用自定义常量.如: namespace Test { class Program { static void Main(string[] args) { const double PI = 3.141592
.NET中用ICSharpCode.TextEditor自定义代码折叠与高亮

前言 ICSharpCode.TextEditor 是一款非常不错的.NET代码编辑控件,内置了多种高亮语言支持,同时完美支持中文,非常赞! 先来看一下运行效果: 一.项目结构这里需要注意lib文件夹下导入的类库,这个Demo需要这些dll. 二.代码折叠需要实现IFoldingStrategy中的 GenerateFoldMarkers 方法,代码如下: using ICSharpCode.TextEditor.Document; using System; using System.Co
C#的四种基本数据类型

字符类型 char ,存储用''(单引号)括起来的一个字符,例如: char sex='男';//存储性别字符串类型 string ,存储用""(双引号)括起来的一串字符,例如: string address="北京市宣武区牛街北口";//存储地址整数类型 int ,存储整数,例如: int age=23;//存储年龄双精度浮点型 double ,存储小数,例如: double salary=7991.63;//存储工资以上四种是最常用的数据类型. 需要注意
C# Rx的主要接口深入理解

C# Rx的主要接口深入理解 IObservable / IObserver 接口在.NET Framework 4.0基类库中可用,并且它们包含在可以安装在.NET 3.5,Silverlight 3和4以及JavaScript中的包中. IObservable/IObserver Rx将异步和基于事件的数据源公开为基于推送的可观察序列,由.NET Framework 4.0中的新IObservable 接口抽象. 这个IObservable 接口是用于基于拉的,可枚举集合的熟悉的IEnume
基于Java8 函数式接口理解及测试

1. 函数式接口的理解根据重构的思想,需要把容易变化的模块进行抽象并封装起来,从这个点来看,Java8新引入的函数式接口就是基于这个思想进行设计的. 2. 函数式接口定义 2.1 自定义如下需要FunctionalInterface关键字显示声明: @FunctionalInterface public interface AppleInterface { public void test(); } 2.2 系统预定义 java.util.function.Consumer; java.ut
浅谈Java抽象类和接口的个人理解

今天来说一波自己对Java中抽象类和接口的理解,含参考内容: 一.抽象类 1.定义: public abstract class 类名{} Java语言中所有的对象都是用类来进行描述,但是并不是所有的类都是用来描述对象的.我所理解的抽象类其实就是对同一类事物公共部分的高度提取,这个公共部分包括属性和行为.比如牛.羊.猪它们的公共属性是都有毛,公共行为是都哺乳,所以我们可以把公共部分抽象成一个哺乳类,含有属性毛和行为哺乳,当牛.羊.猪继承了哺乳类后也就有了哺乳的功能,至于怎么完成这个功能就需要自己
深入理解Java class文件格式_动力节点Java学院整理

Class文件在Java体系结构中的位置和作用对于理解JVM和深入理解Java语言, 学习并了解class文件的格式都是必须要掌握的功课. 原因很简单, JVM不会理解我们写的Java源文件, 我们必须把Java源文件编译成class文件, 才能被JVM识别, 对于JVM而言, class文件相当于一个接口, 理解了这个接口, 能帮助我们更好的理解JVM的行为:另一方面, class文件以另一种方式重新描述了我们在源文件中要表达的意思, 理解class文件如何重新描述我们编写的源文件, 对于深
PHP面向对象的进阶学习(抽像类、接口、final、类常量)

一.抽像类(abstract) 在我们实际开发过程中,有些类并不需要被实例化,如前面学习到的一些父类,主要是让子类来继承,这样可以提高代码复用性语法结构: 复制代码代码如下: abstract class 类名{ 属性 $name; 方法(){} //方法也可以为abstract 修饰符 function 方法名(){} } 例: 复制代码代码如下: abstract class animal{ public $name; public $age; //抽象方法不能有方法体,主要是为了让子
Java接口的简单定义与实现方法示例

本文实例讲述了Java接口的简单定义与实现方法.分享给大家供大家参考,具体如下: 1.接口是Java中最终要的概念,接口可以理解为一种特殊的类,里面全部是由全局常量和公共的抽象方法所组成. 2.接口的格式: interface interfaceName{ 全局常量抽象方法 } 3.接口的实现也必须通过子类,使用关键字implements,而且接口是可以多实现的. 4.一个子类可以同时继承抽象类和实现接口. 5.一个接口不能继承一个抽象类,但是却可以通过extends关键字同时继承多个接口,实
Java并发编程之Executor接口的使用

一.Executor接口的理解 Executor属于java.util.concurrent包下: Executor是任务执行机制的核心接口: 二.Executor接口的类图结构由类图结构可知: ThreadPoolExecutor 继承了AbstractExecutorService接口: AbstractExecutorService接口实现了ExecutorService接口: ExecutorService继承了Executor接口: 因此以下部分主要讲解ThreadPoolExecu
Java语法之 Java 的多态、抽象类和接口

目录一.多态 1. 向上转型 2. 动态绑定 3. 方法重写 4. 向下转型 5. 关键字 super 6. 在构造方法中调用重写方法(坑) 7. 理解多态 8. 小结二.抽象类 1. 概念 2. 注意事项 3. 抽象类的意义 3. 抽象类的作用三.接口 1. 语法规则 2. 实现多个接口 3. 接口的继承 4. Comparable 接口 4. Comparator 接口 5. Cloneable 接口和深拷贝上一篇文章:Java 基础语法之解析 Java 的包和继承今天这章主要介绍
详解Java 中的函数式接口

目录 @FunctionalInterface注解最简单的函数式接口基础数据类型的函数表达式二元输入参数的函数 Two-Arity Function Specializations Suppliers 供给型接口 & Consumers 消费型接口 Predicates 断言型接口 Operators 总结 @FunctionalInterface注解如果你想自己定义个新的函数式接口,强烈建议你加上*@FunctionalInterface* 注解.可以更好地揭示我们定义这个接口的意思,
Java十分钟精通接口的使用与原理

何为接口? 官方解释: Java内的接口是一系列方法的声明,是一些方法特征的集合,一个接口只有方法的特征没有方法的实现,因此这些方法可以在不同的地方被不同的类实现,而这些实现可以具有不同的行为(功能). 个人理解解释: 其实接口可以理解为一种特殊的类,这个类里面全部是由全局常量和**公共的抽象方法(需要重写)所组成.接口是解决Java无法使用多继承的一种手段.我们可以把接口理解为是一个100%的抽象类,既接口中的方法必须全部是抽象方法.反正接口里面都是方法,但是没有方法体,其他类实现这个接口后重

C# Rx的主要接口深入理解

相关推荐

随机推荐