问一个关于 RxJS 的技术问题 - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
推荐关注
Meteor
JSLint - a Javascript code quality tool
jsFiddle
D3.js
WebStorm
推荐书目
Javascript 权威指南第 5 版
Closure: The Definitive Guide
vsomeone
V2EX    Javascript

问一个关于 RxJS 的技术问题

  •  
  •   vsomeone 2020-10-10 11:22:54 +08:00 2283 次点击
    这是一个创建于 1903 天前的主题,其中的信息可能已经有所发展或是发生改变。

    现在有一个需求,封装的 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<DataType>; onBChange(newB: TypeOfB) { this.subscriptionToC.unsubscribe(); this.subscriptiOnToC= newB.C.subscribe( source$.next ); } } 

    这样当然能够解决问题,但是感觉很脏,因为引入了一个多余的 subscription,需要在 A 的生命周期内进行额外的管理操作,并且需要手动地关注 B 什么时候会发生变化。

    由于不精通 RxJS,不知道能不能通过什么 operator 实现这个目标,希望大家帮忙解答~

    4 条回复    2020-10-10 21:52:46 +08:00
    gdtdpt
        1
    gdtdpt  
       2020-10-10 11:40:04 +08:00
    我感觉应该是你需要一个 Observable<B>然后再由 B -> flatMap 到 C,这样 B 改变后流也会执行当前 B 中的 C 。RxJS 好久不用了,可能不太对。
    cuzfinal
        2
    cuzfinal  
       2020-10-10 14:57:04 +08:00
    把 C 设置成一个 BehaviorSubject,然后在 A 的内部处理 B 的 subscribe 和 unsubscribe,每次接收到新的数据时直接 c.next(data),C 一直不变,这样就能直接把 C 暴露给用户了。
    faceRollingKB
        3
    faceRollingKB  
       2020-10-10 16:22:31 +08:00   1
    因为你的 B 也是动态改变的,所以不手动 unsubscribe+ subscribe 的方案需要你把 B 转化为 observable B$,然后从外部订阅 B$.pipe(switchMap(B => B.C))才行,当然只是想法我没试过
    akatquas
        4
    akatquas  
       2020-10-10 21:52:46 +08:00
    https://rxjs-dev.firebaseapp.com/api/index/class/Subject#asObservable

    Observable 存在这个 API 来同源创建一个新的 observable,值得一试
    关于     帮助文档     自助推广系统     博客     API     FAQ     Solana     5153 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 35ms UTC 07:46 PVG 15:46 LAX 23:46 JFK 02:46
    Do have faith in what you're doing.
    ubao msn snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86