正确显示可观察的对象值

// 引入RxJS库
const { Observable } = require('rxjs');

// 创建一个可观察对象
const myObservable = new Observable(observer => {
  observer.next(1); // 发出第一个值
  observer.next(2); // 发出第二个值
  setTimeout(() => {
    observer.next(3); // 异步发出第三个值
    observer.complete(); // 完成可观察对象
  }, 1000);
});

// 订阅可观察对象
const subscription = myObservable.subscribe({
  next(x) { console.log('got value ' + x); },
  error(err) { console.error('something wrong occurred: ' + err); },
  complete() { console.log('done'); }
});

// 如果需要取消订阅
// subscription.unsubscribe();

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

of(1, 2, 3).pipe(
  catchError(err => {
    console.error('Error:', err);
    return of('Fallback value'); // 返回一个备选值
  }),
  finalize(() => console.log('Cleanup or final action'))
).subscribe({
  next: value => console.log('Value:', value),
  complete: () => console.log('Completed')
});