RxJS 订阅未触发

Question

目前正在学习 RxJS。我在一个服务中有一个整数selectedCourseIndex，我想要一个单独的组件来订阅。

courses-section.service.ts

private selectedCourseIndex: number = -1; //this number can change from another method
private selectedCourseIndexUpdated = new Subject<number>();

getSelectedCourseUpdateListener(){
    return this.selectedCourseIndexUpdated.asObservable();
}

courses-section.component.ts

  private selectedCourseIndex: number = -1; //Placeholder initial selectedCourseIndex until new one given on init from courses-section service
  private selectedCourseSub: Subscription;

  constructor( public coursesSectionService: CoursesSectionService ){}

  ngOnInit(){
   this.selectedCourseIndex = 
   this.coursesSectionService.getSelectedCourseIndex();
   this.selectedCourseSub = this.coursesSectionService
    .getSelectedCourseUpdateListener()
    .subscribe((selectedCourseIndex: number) => {
      this.selectedCourseIndex = selectedCourseIndex;
      console.log('this fires when subscription updates'); //this never fires once
    });
  }

但是，无论是在最初订阅时还是在整数更改时，订阅都不会触发。怎么了？

Answer 1

“Subject” observable 不会在订阅时重播之前的值。仅当您在服务中执行以下操作 [以某种方式] 时，您的订阅才会触发 -

this.selectedCourseIndexUpdated.next(<your new number>);

要在每个订阅上触发订阅 [获取最后发出的值]，您应该使用“BehaviorSubject”而不是像这样的主题 -

private selectedCourseIndexUpdated = new BehaviorSubject<number>(0);

BehaviorSubject 重播每个订阅上最后发出的值。注意 BehaviorSubject 构造函数采用默认值。

Answer 2

如果我错了，请纠正我，

您的问题：您想要一个可观察对象的当前（或最新）值，而不管是否有人现在发出了一个值。

回答： Subject 或 Observable 没有当前值。当一个值被发出时，它被传递给订阅者，并且 observable 完成了它。 Observable 只有在向主题流发出另一个值时才会起作用。

如果您想获得当前值，请使用专为您需要的目的而设计的 BehaviorSubject，它会保留最后发出的值，无论何时发出并立即将其传达给新的订阅者。

注意：它还有一个方法 getValue() 来获取当前值。

---

您面临的另一个问题。

问题：您当前的代码似乎不起作用。

回答： 让我举个例子说明我如何使用 Observable -

Courses-action.service.ts

import { Injectable } from ‘@angular/core’;
import { Subject } from ‘rxjs’;

@Injectable()
Export class CoursesActionService {
  Public selectedCourseIndexUpdated = new Subject<any>();
  Public isCourseIndexUpdated$ = this.selectedCourseIndexUpdated.asObservable();

Public announceSelectedCourseIndex(response: any) {
  this.selectedCourseIndexUpdated.next(response);
}

一些向订阅者发出值的随机文件 -

this.coursesActionService.announceSelectedCourseIndex(453);

监听发射值的一些随机文件 -

this.coursesActionService.isCourseIndexUpdated$.pipe(takeUntil(this.destroyed$))
.subscribe(res => console.log(‘i have the response’, res));