Наблюдаемый не подписывающийся при использовании трубы в Rxjs - Angular

Question

Следующий код не подписывается:

this.store
      .select(petSelectors.selectPetData)
      .pipe(find(x => x.petName === petName)).subscribe(x => console.log(x));

Но если я делаю это, он делает подписку:

this.store.select(petSelectors.selectPetData).subscribe(x => console.log(x));

ОБНОВЛЕНИЕ: это тоже работает

const x = this.store .select(petSelectors.selectPetData).pipe(find(x => x));

, но когда я добавляю логику, это не

Я следую официальной документации RxJS: https://rxjs -dev.firebaseapp.com / api / operator / find

Я даже пробовал внутри pipe(), try with take(1), map(), etc, и когда я делаю .subcribe(), ничего не печатается.Я также пытался использовать async трубу.

Объект:

{
  "petName": "devpato"
}

Имя питомца, которого я передаю, - это сравнение объектас 'devpato'

Answer 1

Нашел мою проблему! @ConnorsFan в основном x => x.petName === petName не работает, потому что x - это весь массив , а не единственный объект внутри массива. Так что мне нужно вмешиваться через x

.pipe(map(x => x.find(u => u.petName ===petName));