Rxjs 5：如何建立Observable链？

我是RxJS的新手，我试图实现与MS-Excel完全相同的可观察链。概念：让我们假设excel有5个专栏'姓名'，'年龄'，'性别'，'国家'，'邮编'。我们可以对每列独立应用过滤器，这也会影响其他列中显示的记录。Rxjs 5：如何建立Observable链？

这里数据源接收数据后端服务，数据源只有两个函数“addRecord”&“removeRecord”。

我如何在这里实现可以说我将创建Observable并附加到数据源调用它作为OBS-1这将从数据源接收数据。 OBS-1可以有自己的过滤器。假设我将创建另一个将接收数据OBS-1的Observable OBS-2（过滤数据，如果OBS-1中有任何过滤器）。另一个可观察的说OBS-3再次从OBS-2接收数据（如果OBS-2中有任何数据，则进行过滤）等等。

如果OBS-2被破坏（取消订阅），OBS-3将从OBS-1接收数据。

我们如何在RxJs中实现这一目标？

来源

2017-03-03 user3130446

我想你误解了Rx的一些问题。可观察对象没有过滤器，而且您不能“过滤”添加和移除过滤器。基于订阅者的观察数据也不可观察。

而是建立一个呼叫链。您从源观察开始，如addRecord中的一个和removeRecord事件中的一个。然后，您将这些可观测量链接到Rx中的各种operators形成新的观测值，最终您订阅最终可观测值。订阅将激活整个链条，并且当源事件触发时，所有操作员将触发并最终该事件（如果未被过滤）达到subscribe。

你实际上可以做你在Rx中描述的东西。使用switchMap这个可以让你将一个序列投影到另一个序列并每次切换到新序列的操作符都可以相对简单地更改可观察对象上的过滤器。例如filterSource.switchMap(filterFunction => Obs-1.filter(filterFunction))。即使比这更简单，您可以退订第一次订阅并重新设置Rx链。然而，使用构建函数会使等式中出现很多杂耍状态。

但是，我强烈怀疑你并不需要这种复杂的行为。你想要的东西可以像这样存档：

var Src-1 = fromEvent(dataSource, 'addRecord') // create the first source 
var Src-2 = fromEvent(dataSource, 'removeRecord') // and the other source 
var Obs-1 = Src-1.combineLatest(Src-2) // combine both sources 
    .filter(e => someCondition(e)) // filter the source 
var Obs-2 = Obs-1.mergeMap(e => someOtherCondition(e) ? Change(e) : Rx.Observable.of(e)) // on someOtherCondition, either transform the source with the `Change(e)` function. Or keep it unchanged with `of(e)` 
var Obs-3 = Obs-2.filter(e => anotherCondition(e)) // Filter again 
var sub = Obs-3.subscribe() // activate the sequence.

来源

2017-03-03 22:49:08 Dorus

感谢您纠正我。每个观察者（OBS-1，OBS-2等）都可以有自己的订阅，它将接收数据。实际上观察将被动态添加。我们如何做到这一点？ – user3130446

你如何动态接收observables？你不是指订阅吗？我认为你需要更具体地了解你想要的以及你的来源是什么导致了这些变化。 Rx是关于反应式程序设计的，在反应式程序设计中，了解数据来自哪里，而不是如何操作它很重要。一旦你的信息来源清晰，其余的就会落实到位，现在你似乎在寻找错误的解决方案。 – Dorus

Rxjs 5：如何建立Observable链？

回答

相关问题