详解Angular中的Observable（可观察对象）

本篇文章带大家了解一下Angular 可观察对象(Observable)。有一定的参考价值，有需要的朋友可以参考一下，希望对大家有所帮助。

可观察对象(Observable)

可观察对象支持在应用的发布者和订阅者之间传递消息。

可观察对象是声明式的 —— 即定义的用于发布值的函数，在有消费者订阅它之前，这个函数不会实际执行。

可观察对象可能会发出的三种通知：

定义观察者

观察者(observer)： 用于接收可观察对象通知的处理器要实现 Observer 接口，这个对象定义了一些回调函数来处理可观察对象可能会发来的三种通知。

观察者对象可以定义这三种处理器的任意组合。如果你不为某种通知类型提供处理器，这个观察者就会忽略相应类型的通知。

// Create observer object
const myObserver = {
    next: (_data) => {
        // next通知类型处理器
    },
    error: err => {
        // error通知类型处理器
    },
    complete: () => console.log('Observer got a complete notification'),
};

订阅

只有当Observable的实例被订阅时，Observable实例才会发布值。订阅时要先调用该实例的subscribe() 方法，并把一个观察者对象传给它，用来接收通知。

语法：Observable.subscribe(ObserverObject)，其中，Observable为可观察对象实例，ObserverObject为观察者对象。

// 官网示例
// Create simple observable that emits three values
const myObservable = of(1, 2, 3);
 
// Create observer object
const myObserver = {
    next: x => console.log('Observer got a next value: ' + x),
    error: err => console.error('Observer got an error: ' + err),
    complete: () => console.log('Observer got a complete notification'),
};
 
// Execute with the observer object
myObservable.subscribe(myObserver);
// Logs:
// Observer got a next value: 1
// Observer got a next value: 2
// Observer got a next value: 3
// Observer got a complete notification

另外，subscribe() 方法还可以接收定义在同一行中的回调函数，无论 next、error 还是 complete 处理器。比如，下面的 subscribe() 调用和前面指定预定义观察者的例子是等价的。

myObservable.subscribe(
    x => console.log('Observer got a next value: ' + x),
    err => console.error('Observer got an error: ' + err),
    () => console.log('Observer got a complete notification')
);

注： 无论哪种情况，next通知类型的处理器是必要的，而error和complete处理器是可选的。

subscribe() 调用会返回一个 Subscription 对象，该对象具有一个 unsubscribe()方法。 当调用该方法时，你就会停止接收通知。