new Observable(...) 和 Rx.Observable.create(...) 之间的区别

JS

Rx.Observable.create() 和 new Observable(...) 都是创建一个可观察对象，用于实现响应式编程。然而，它们之间存在一些区别。

new Observable(...)

new Observable(...) 是 RxJS 5 之前的创建可观察对象的方式。它接受一个函数作为参数，该函数定义了可观察对象的行为。这个函数被称为"订阅函数"，它接受一个观察者作为参数，并在订阅时执行。订阅函数可以在任何时候调用观察者的 next、error 和 complete 方法。

下面是一个使用 new Observable(...) 创建可观察对象的示例代码：

Javascript
const observable = new Observable(observer => {
  observer.next('Hello');
  observer.next('World');
  observer.complete();
});

在上面的例子中，我们创建了一个可观察对象，它在订阅时向观察者发送了两个值，然后完成了。

Rx.Observable.create()

Rx.Observable.create() 是 RxJS 5 之后的创建可观察对象的方式。它的使用方式与 new Observable(...) 类似，也接受一个订阅函数作为参数。然而，Rx.Observable.create() 提供了更多的灵活性和功能。

下面是一个使用 Rx.Observable.create() 创建可观察对象的示例代码：

Javascript
const observable = Rx.Observable.create(observer => {
  observer.next('Hello');
  observer.next('World');
  observer.complete();
});

在上面的例子中，我们使用 Rx.Observable.create() 创建了一个可观察对象，它与使用 new Observable(...) 创建的对象实际上是相同的。

区别

尽管两种方式都可以创建可观察对象，但是 Rx.Observable.create() 提供了更多的灵活性。使用 Rx.Observable.create() 可以更方便地处理错误、取消订阅以及使用操作符来转换可观察对象。

使用操作符转换可观察对象

RxJS 提供了许多操作符，可以用于转换、过滤和组合可观察对象。使用 Rx.Observable.create() 创建的可观察对象可以通过链式调用这些操作符来进行转换。

下面是一个使用 Rx.Observable.create() 和操作符转换可观察对象的示例代码：

Javascript
const observable = Rx.Observable.create(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.complete();
}).map(value => value * 2);
observable.subscribe(value => console.log(value)); // 输出 2, 4, 6

在上面的例子中，我们使用 Rx.Observable.create() 创建了一个可观察对象，并使用 map 操作符将每个值乘以2。最后，我们订阅了转换后的可观察对象，并打印出转换后的值。

处理错误和取消订阅

使用 Rx.Observable.create() 创建的可观察对象还可以更方便地处理错误和取消订阅。通过在订阅函数中调用观察者的 error 方法，可以在发生错误时通知观察者。而通过返回一个取消订阅函数，可以在需要时取消订阅。

下面是一个使用 Rx.Observable.create() 处理错误和取消订阅的示例代码：

Javascript
const observable = Rx.Observable.create(observer => {
  try {
    observer.next(1);
    observer.next(2);
    throw new Error('Something went wrong');
    observer.next(3);
    observer.complete();
  } catch (error) {
    observer.error(error);
  }
  return () => console.log('Unsubscribed');
});
const subscription = observable.subscribe(
  value => console.log(value),
  error => console.error(error),
  () => console.log('Completed')
);
// 输出：
// 1
// 2
// 错误：Something went wrong
// 取消订阅

在上面的例子中，我们在订阅函数中抛出了一个错误，并通过调用观察者的 error 方法通知观察者。然后，我们返回一个取消订阅函数，并在取消订阅时打印出一条消息。在订阅时，我们提供了一个错误处理函数和完成处理函数，以便处理错误和完成事件。

总的来说，Rx.Observable.create() 提供了更灵活和功能丰富的创建可观察对象的方式。它可以更方便地使用操作符转换可观察对象，并提供了处理错误和取消订阅的机制。因此，在使用 RxJS 5 或更高版本时，推荐使用 Rx.Observable.create() 来创建可观察对象。