RxJS :如何在Angular中从外部和内部可观察对象获取输出

import { Observable } from 'rxjs';

// 外部可观察对象
const externalObservable = new Observable(observer => {
  // 模拟异步操作
  setTimeout(() => {
    observer.next('Hello from external observable!');
    observer.complete();
  }, 1000);
});

// 订阅外部可观察对象
externalObservable.subscribe(
  value => {
    console.log(value); // 输出：Hello from external observable!
  },
  error => {
    console.error(error);
  },
  () => {
    console.log('Complete');
  }
);

import { Component } from '@angular/core';
import { Observable } from 'rxjs';

@Component({
  selector: 'app-example',
  template: `
    <div>{{ internalObservable$ | async }}</div>
  `
})
export class ExampleComponent {
  // 内部可观察对象
  internalObservable$: Observable<string>;

  constructor() {
    // 模拟异步操作
    this.internalObservable$ = new Observable(observer => {
      setTimeout(() => {
        observer.next('Hello from internal observable!');
        observer.complete();
      }, 1000);
    });
  }
}