subscribe() 和 unsubscribe() 上的操作

Question

在 RxJS 中，一旦观察者订阅了 Observable 以及取消订阅，我想采取一些特殊的操作。我当然可以覆盖subscribe()和unsubscribe()方法，但这看起来很粗鲁。在创建可观察对象期间是否有一种方法可以提供每当有人订阅/取消订阅时就会调用的回调？BR，丹尼尔

Answer 1

这就是Observable.create目的。您可以使用指定的附加/分离处理程序创建自己的可观察量，甚至可以仅用另外两行代码来包装现有的可观察量。

const obs = Rx.Observable.create(observer => {
  console.log('attach');
  // If you want to wrap another observable, call this:
  // const subs = other.subscribe(observer);
  return () => {
    // subs.unsubscribe();
    console.log('detach');
  };
});

console.log('subscribe subscription1');
const subscribtion1 = obs.subscribe(() => {});
console.log('subscribe subscription2');
const subscribtion2 = obs.subscribe(() => {});
setTimeout(() => {
  console.log('subscribtion1.dispose()');
  subscribtion1.unsubscribe();
}, 500);
setTimeout(() => {
  console.log('subscribtion2.dispose()');
  subscribtion2.unsubscribe();
}, 1000);

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.0.0-rc.4/Rx.js"></script>