如何解决RXJS-避免内部订阅
试图找出我需要的食谱,但找不到任何地方。
我有类似这样的代码。
const Listeners = listen("data:join"); /* observable of people who want data */
const DataStream = stream("data"); /* observable of data */
我如何建立一个管道:
- 对于每个加入我的侦听器流的
person
,我都将其订阅到数据流。 - 每个触发
data:leave
事件的人都从信息流中退订 - DataStream在引擎盖下的一长串列表仅对每个加入人员触发一次,而不触发一次。
编辑:以内存安全的方式等效于此:
Listeners.subscribe((personListening) => {
DataStream.subscribe((data) => personListening.send(data))
// And until fromEvent(personListening,"data:leave") fires.
})
/* OR */
DataStream.subscribe((data) => {
Listeners.subscribe((person) => {
person.send(data);
})
})
解决方法
我不确定您的可观察行为,但是从总体上讲,您可以使用任何RxJS高阶映射运算符(例如env
,python3
等-差异{{3 }})从一个可观察到另一个的映射。并使用RxJS here运算符根据另一个可观察对象完成/取消订阅一个可观察对象。
关闭组件后,您也可以使用switchMap
关闭所有打开的订阅。
尝试以下
concatMap
,
我认为您想跳过并接受rxjs的运算符。
示例:
const data = interval(1000);
const start = timer(4500);
const end = timer(21800);
data.pipe(
skipUntil(start),takeUntil(end),).subscribe(console.log);
data
在这里是连续的发射流,每秒发射的次数增加。 start
和end
在定义的时间后发射一次。在控制台中,您将看到有限范围的流数据。
Stackblitz:https://stackblitz.com/edit/rxjs-ccdfif?file=index.ts
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。