核心的两个接口
public interface IObservable<T>
{
IDisposable Subscribe(IObserver<T> observer);
}
public interface IObserver<T>
{
void OnCompleted();
void OnError(Exception error);
void OnNext(T value);
}下面 解释下这两个接口
IObservable 是一个可被观察的发射源，观察者（observer）要观察他的发射需要进行一个订阅(subscribe)
并把注销器交给观察者(返回值:IDisposable)
订阅后就能接收到Observable发射来的数据，数据的类型就是T
（发射源的发射会转交给调度器执行，比如按固定时间间隔发射、每帧发射、只发射n次等等）
而 IObserver 是一个观察别人发射的观察者 ，他需要知道当他接收到数据时要对数据干嘛（OnNext(T)）
需要知道异常时干嘛（OnError） ,观察结束时要干嘛（OnCompleted）
（在回调OnCompleted执行时（发射源结束了发射）,注销器会被自动调用）
(而当主动调用注销器时，OnCompleted不会被调用)