rx.js Observable 剖析（创建，订阅，执行，清理 ）

Posted 2020-10-29 ajanuw

文档 http://cn.rx.js.org/manual/overview.html#h24

Observables 是使用 Rx.Observable.create 或创建操作符创建的，并使用观察者来订阅（subscribe）它，然后执行它并发送 next / error / complete 通知给观察者，而且执行可能会被清理（unsubscribe）。

const { Observable } = require('rxjs');

// 创建 Observables
var observable = Observable.create(observer => {
    var id = setInterval(() => {
        observer.next('hi')
    }, 1000);

    // 提供取消和清理 interval 资源的方法
    return function unsubscribe() {
        clearInterval(id);
    };
});

// Observer (观察者，執行)
var observer = {
    next(res) {
        format(res)
    },
    error(err) {
        format(err)
    },
    complete() {
        format('done.')
    },
};

// 订阅 Observables
var subscription = observable.subscribe(observer);

// .add() 合并多个订阅，以便同时取消订阅
// subscription.add(childSubscription);

// 撤销 add的合并
// subscription.remove(childSubscription);

// 3s后取消订阅
setTimeout(() => {
    subscription.unsubscribe();
}, 3000)