合并函数内部的 RxJS 映射函数

Question

我正在尝试合并 3 个不同的 observables 并将它们标识为源值。此外，我在 withLatestfrom 中获取了 userDetails，以便我可以根据触发的 observable 进行操作（用户名 - u，密码 - p，年龄 - a）。我确信我将地图函数放在 Observable.merge 中这一事实有问题，这就是为什么无论哪个 Observable 应该触发我的源在“switch case”语句中总是'u'。

@Effect
public test = Observable.merge(
  this.onUserNameUpdate().pipe(
    map(() => 'u')),
    this.onPasswordUpdate().pipe(
      map(() => 'p')), 
      this.onAgeUpdate().pipe(map(() => 'a')))
        .withLatestFrom(this.store.select(getUserDetails),
      (source, userDetails) => ({
        source,
        order
      })
  )
  .map((params) => {
    switch (params.source) {
      case 'u':
        // do smth with username
      case 'p':
        // do smth with password
      case 'a':
        // do smth with age
    }
    return {
      // some object
    }
  })

谁能解释我在这里做错了什么？

Answer 1

请尝试将第一个混合（pipe 和可观察运算符）部分替换为一些纯 RxJS 5 可观察数组：

public test = Observable
.merge(
  this.onUserNameUpdate()
  .map(v => 'u'),
  this.onPasswordUpdate()
  .map(v => 'p'),
  this.onAgeUpdate()
  .map(v => 'a')
)

看看你的开关/机箱是否相应移动。

我还看到您会根据可观察到的触发操作的来源获得更多用户详细信息，我会将其附在 concatMap 中：

.concatMap((trigger) => {
    return this.store.select(getUserDetails)
    .map(user => {
       let ret = user;
       ret.trigger = trigger;;
    })
})

最后你得到了带有元数据的用户信息以及触发变化的原因

编辑

由于上述代码，您的流应该是这样的：
每个发出 observable 结果的 onXXXUpdate 函数都使用 merge 运算符合并：
http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#static-method-merge
因为合并运算符返回单个可观察对象，该可观察对象能够发出它的“子”可观察对象发出的每种值类型，所以在下一个运算符concatMap 中，我们将每个发出的值（不管它的源）映射到作为@ 输出创建的新可观察对象987654329@（我假设这个函数返回 observable，不是吗？）。为了跟踪触发器是什么，我们通过map将此信息作为元数据附加到用户信息响应中。之后，在最终操作符中，我们将获得用户信息和触发信息，以帮助区分应采取的操作。