在具有rxJs的角度2中的2个不同组件中订阅相同的流

import { Subject } from 'rxjs';

export const sharedStream$ = new Subject<any>();

import { sharedStream$ } from 'shared.service';

@Component({
  // component configuration
})
export class Component1 implements OnInit, OnDestroy {
  private subscription: Subscription;

  ngOnInit() {
    this.subscription = sharedStream$.subscribe(data => {
      // 处理流的数据
    });
  }

  ngOnDestroy() {
    this.subscription.unsubscribe();
  }
}

import { sharedStream$ } from 'shared.service';

@Component({
  // component configuration
})
export class Component2 implements OnInit, OnDestroy {
  private subscription: Subscription;

  ngOnInit() {
    this.subscription = sharedStream$.subscribe(data => {
      // 处理流的数据
    });
  }

  ngOnDestroy() {
    this.subscription.unsubscribe();
  }
}