admin管理员组

文章数量:1345447

I'm trying to use Rxjs as a way to manage garbage collection in a large state tree.

How can I create an operator that takes a callback function that is triggered every time the number of subscribers to the observable alters?

I'm trying to use Rxjs as a way to manage garbage collection in a large state tree.

How can I create an operator that takes a callback function that is triggered every time the number of subscribers to the observable alters?

  • javascript
  • rxjs
Share Improve this question edited Sep 15, 2017 at 21:23 Vadim Kotov 8,2848 gold badges50 silver badges63 bronze badges asked Sep 15, 2017 at 14:53 Peter MorrisPeter Morris 23.3k12 gold badges97 silver badges166 bronze badges
Add a ment  | 

1 Answer 1

Reset to default 15

Multiple ways, all involve hiding your subject and giving consumers a wrapped observable:

Want to know when something subscribes to your subject?

const subject = new Subject();
const observable = Observable.defer(() => {
  someoneJustSubscribed();
  return subject;
});
return observable;

Want to know when someone unsubscribes?

const subject = new Subject();
const observable = subject.finally(() => someoneJustUnsubscribed());
return observable;

Want to know both?

const subject = new Subject();
const observable = Observable.create(observer => {
    someoneJustSubscribed();
    const sub = subject.subscribe(observer);
    return () => {
        someoneJustUnsubscribed();
        sub.unsubscribe();
    }
});
return observable;

本文标签：

版权声明：本文标题：javascript - How can I receive notifications when Rxjs Subject is subscribed tounsubscribed from - Stack Overflow 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.betaflare.com/web/1743812339a2543302.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。