行为主题只有在有新事物的情况下才返回

Question

我有以下问题，当我调用getstudentslist函数时，它将转到服务器以查找所需的新值，但是行为主题再次返回当前值（这会导致我问题，因为它加载了视图，将视图加载到先前的值中）当我等待服务器信息返回时。 我该如何避免这种行为？

  getStudentsList(params): Observable<StudentsListGrid> {
    if (this.studentListSubject$ === undefined) {
      this.studentListSubject$ = new BehaviorSubject<StudentListGrid>(null);
    }
    this.refetchStudentList(params);
    return this.studentListSubject$.asObservable().pipe(filter((value) => value !== null));
  }

  refetchStudentList(gridParams) {
    const subscription = this.http.post<StudentListGrid>(this.baseUrl + 'GetStudents', {gridParams} ,httpOptions).pipe(map(data => this.setDefaultValuesToStudent(data))).subscribe(
      (response) => {

        this.studentListSubject$.next(response);
        subscription.unsubscribe();
      });
  }

Answer 1

基于

行为主题：
主题的变体需要初始值，并在订阅

时发出其当前值

解决方案1

以进行快速解决方案时发出其当前值，您可以在 getSudentslistlist 函数中返回可观察到的null。

  getStudentsList(params): Observable<StudentsListGrid> {
    if (this.studentListSubject$ === undefined) {
      this.studentListSubject$ = new BehaviorSubject<StudentListGrid>(null);
    }
    this.refetchStudentList(params);
    // add this line
    this.studentListSubject$.next(null);
    return this.studentListSubject$.asObservable().pipe(filter((value) => value !== null));
  }

中 通过null通过null来清空行为的最后一个值，因此此函数的返回始终返回新的值。

解决方案2

另一种方法（更好的方法）是使用rxjs库中的不同的企业，我想您的名字在每个响应中都会有所不同：

 getStudentsList(params): Observable<StudentsListGrid> {
    if (this.studentListSubject$ === undefined) {
      this.studentListSubject$ = new BehaviorSubject<StudentListGrid>(null);
    }
    this.refetchStudentList(params);
    return this.studentListSubject$.asObservable().pipe(
             filter((value) => value !== null),
             distinctUntilChanged((prev, curr) => prev.name === curr.name));
  }

希望此答案对您有所帮助。

Answer 2

通常，您不想为了更新另一个可观察到的主题而订阅某些东西。取而代之的是结局的连锁事件。

private studentListTrigger$ = new Subject();

readonly studentList$ = concat(
  of(null), // triggers a refresh the first time something subscribes to studentList$
  this.studentListTrigger$
).pipe(
  switchMap( // if a new request, drop any previous request in progress.
    () => this.http.post<StudentListGrid>(
      this.baseUrl + 'GetStudents',
      {gridParams},
      httpOptions
    ).pipe(
      catchError(() => EMPTY) // don't let the error of any given attempt break studentList$
    )
  ),
  filter((value) => value !== null),
  shareReplay(1) // No matter how many subscribers, as long as there's at least one subscriber, do all of the above exactly once and then emit the last value to any late subscribers just like a BehaviorSubject does
);

refreshStudentList(): void {
  this.studentListTrigger$.next();
}

现在，无论消耗学生列表$什么都将获得最后的结果，并在每次刷新时都会收到新的学生列表。