对RxJS中的订阅（）和取消订阅（）

Question

采取的行动我想在观察者订阅Observable并取消订阅时采取一些特殊操作。我当然可以覆盖subscribe()和unsubscribe()方法，但看起来很糟糕。 在创建observable时，没有办法提供回调函数，每当有人订阅/取消订阅时都会调用回调函数。 BR， Daniel

Answer 1

这是Observable.create的用途。您可以使用指定的附加/分离处理程序创建自己的observable，甚至可以仅用2行代码来包装现有的observable。

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>