技术解析
现在有一个需求,封装的 class A 内包含了一个 private member B,B 有一个开放的 observable C,A 能够访问到 C 。
现在需要通过 A 将 C 封装起来给外界的使用者形成一个新的 API (命名为 source$)。
需要注意的是,由于一个 A 的生命周期中 B 可能会变化,因此不能直接把 C 暴露给用户(即 source$ = C,否则当用户 source$.subscribe(cb) 后,如果 B 变化导致 C 变化,这个 subscription 实际上会失效)。
目前我的方案是:
class A {
private B: TypeOfB;
private subscriptionToC: Subscription;
public source$: Subject;
onBChange(newB: TypeOfB) {
this.subscriptionToC.unsubscribe();
this.subscriptionToC = newB.C.subscribe(
source$.next
);
}
}
这样当然能够解决问题,但是感觉很脏,因为引入了一个多余的 subscription,需要在 A 的生命周期内进行额外的管理操作,并且需要手动地关注 B 什么时候会发生变化。
由于不精通 RxJS,不知道能不能通过什么 operator 实现这个目标,希望大家帮忙解答~