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

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)