加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 综合聚焦 > 服务器 > 安全 > 正文

angular – RxJS Observable:订阅丢失了吗?

发布时间:2020-12-17 07:30:38 所属栏目:安全 来源:网络整理
导读:以下两个可观察映射之间有什么区别? (如果以下代码中的某些内容对您来说很奇怪:它源于一个边做边学的爱好项目;我仍然学习RxJS) 我有一个带有getter和构造函数的组件.两者都从应用程序的ngrx存储中读取信息并提取字符串(名称). getter和构造函数之间的唯一
以下两个可观察映射之间有什么区别?

(如果以下代码中的某些内容对您来说很奇怪:它源于一个边做边学的爱好项目;我仍然学习RxJS)

我有一个带有getter和构造函数的组件.两者都从应用程序的ngrx存储中读取信息并提取字符串(名称).

getter和构造函数之间的唯一区别:getter在HTML中使用,它返回的observable通过异步管道发送,而构造函数中的observable映射由订阅使用subscribe完成.我希望它们都可以随着名称的新值变得频繁而激活.

但是只有getter以这种方式工作并在HTML中提供异步管道,并在其中使用新的name值(每次更改名称时都会调用console.log(‘A’)).订阅订阅的回调只被调用一次:console.log(‘B’)和console.log(‘B!’)都被调用一次,而不再被调用.

如何解释这种行为差异?

我的组件的片段:

// getter works exactly as expected:
get name$(): Observable<string> {
  console.log('getter called')
  return this.store
    .select(this.tableName,'columns')
    .do(_ => console.log('DO (A)',_))
    .filter(_ => !!_)
    .map(_ => _.find(_ => _.name === this.initialName))
    .filter(_ => !!_)
    .map(_ => {
      console.log('A',_.name)
      return _.name
    })
}

// code in constructor seems to lose the subscription after the subscription's first call:
constructor(
  @Inject(TablesStoreInjectionToken) readonly store: Store<TablesState>
) {
  setTimeout(() => {
    this.store
      .select(this.tableName,'columns')
      .do(_ => console.log('DO (B)',_))
      .filter(_ => !!_)
      .map(_ => _.find(_ => _.name === this.initialName))
      .filter(_ => !!_)
      .map(_ => {
        console.log('B',_.name)
        return _.name
      })
      .subscribe(_ => console.log('B!',_))
  })
}

附加信息:如果我添加ngOnInit,则在整个测试期间只调用一次生命周期挂钩.如果我将订阅从构造函数移动到ngOnInit生命周期钩子,它不会比在构造函数中更好地工作.完全相同(意外)的行为.这同样适用于ngAfterViewInit和其他生命周期钩子.

名称的输出更改’some-name’ – > ‘some-other-name’ – > ‘some-third-name’ – > ‘some-fourth-name’ – > “一些,第五名”:

[更新]正如Pace在评论中所建议的,我添加了getter通话记录

[UPDATE]根据Pace的建议添加了dos

getter called
DO (A) (3) [{…},{…},{…}]
A some-name
DO (B) (3) [{…},{…}]
B some-name
B! some-name
getter called
DO (A) (3) [{…},{…}]
A some-other-name
getter called
DO (A) (3) [{…},{…}]
A some-third-name
getter called
DO (A) (3) [{…},{…}]
A some-fourth-name
getter called
DO (A) (3) [{…},{…}]
A some-fifth-name

dos中console.logs打印的输出示例内容:

[
  {
    "name": "some-name"
  },{
    "name": "some-other-name"
  },{
    "name": "some-third-name"
  }
]

似乎订阅订阅在第一次调用后丢失.但为什么?

从ngrx.select()返回的Observable只会在商店中的数据发生变化时触发.

如果你希望在initialName更改时触发Observable,那么我建议将initialName转换为RXJS主题并使用combineLatest:

initialNameSubject = new BehaviorSubject<string>('some-name');

constructor(
  @Inject(TablesStoreInjectionToken) readonly store: Store<TablesState>
) {
  setTimeout(() => {
    this.store
      .select(this.tableName,'columns')
      .combineLatest(this.initialNameSubject)
      .map(([items,initialName]) => items.find(_ => _.name === initialName))
      .filter(_ => !!_)
      .map(_ => {
        console.log('B',_))
  })
}

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读