Angular 7来自可观察订阅的奇怪行为

import { Subject } from 'rxjs';
import { takeUntil } from 'rxjs/operators';

@Component({
  // ...
})
export class MyComponent implements OnInit, OnDestroy {
  private unsubscribe$ = new Subject<void>();

  ngOnInit() {
    someObservable$.pipe(
      takeUntil(this.unsubscribe$)
    ).subscribe(data => {
      // 处理数据
    });
  }

  ngOnDestroy() {
    this.unsubscribe$.next();
    this.unsubscribe$.complete();
  }
}

import { shareReplay } from 'rxjs/operators';

const sharedObservable$ = someObservable$.pipe(
  shareReplay(1)
);

sharedObservable$.subscribe(data => {
  // 第一个订阅者处理数据
});

sharedObservable$.subscribe(data => {
  // 第二个订阅者处理数据
});

import { catchError } from 'rxjs/operators';
import { of } from 'rxjs';

someObservable$.pipe(
  catchError(error => {
    console.error('发生错误:', error);
    return of(null); // 返回一个空的可观察以继续流
  })
).subscribe(data => {
  // 处理数据
});

import { concatMap } from 'rxjs/operators';

someObservable$.pipe(
  concatMap(asyncData => asyncFunction(asyncData))
).subscribe(result => {
  // 处理结果
});