Rxjs源码解析Observable

RxJS 是一个用于使用 Observables 进行异步编程的库。Observable 是 RxJS 的核心概念，它代表了一个可以发出值的对象。

在 RxJS 中，Observable 可以通过多种方式进行创建和操作。以下是创建 Observable 的一个简单示例：

import { Observable } from 'rxjs';
 
// 创建一个简单的 Observable
const myObservable = Observable.create((observer) => {
  // 发出值
  observer.next('Hello, world!');
  // 完成流
  observer.complete();
 
  // 返回一个取消订阅的函数（如果需要）
  return () => {
    console.log('Observable has been unsubscribed');
  };
});
 
// 订阅 Observable 并处理其发出的值
myObservable.subscribe({
  next: (value) => console.log(value),
  error: (error) => console.error(error),
  complete: () => console.log('Completed'),
});

在这个例子中，我们使用 Observable.create 方法创建了一个新的 Observable。我们传入了一个函数，该函数接收一个 observer 对象，我们可以通过这个 observer 对象来发出值（next）、错误（error）和完成（complete）通知。

然后我们调用 subscribe 方法来订阅这个 Observable，并提供回调函数来处理不同的通知。这个模式是 RxJS 异步编程的核心。