时间戳

首页 > 解决方案 > RxJs 中的“new Observable()”和“of()”有什么区别

angular - RxJs 中的“new Observable()”和“of()”有什么区别

问题描述

new Observable()in和of()in和有什么不一样RxJs？

在我的测试用例中，当我尝试返回时new Observable()，它给了我一个有线错误，如果我用of()来自 Rxjs 的替换它，它工作正常。

我的印象是Observable.create()，new Observable()并且of()做同样的事情。

someService.getMethod().pipe(
  ...
  catchError((e) => {
    // some operation
    // return new Observable(false as any);  // ----> creates error
    return of(false as any); // this works perfectly
  })
)

标签： angularrxjsrxjs6

解决方案

Observable.create()并且new Observable()基本上做同样的事情。

来自 Observable 的解剖学：

Rx.Observable.create是 的别名Observable constructor，它有一个参数：subscribe函数。

Observable.of, 另一方面是关于 的static方法Observable。它为您创建一个，它会Observable立即一个接一个地发出您指定为参数的值，然后发出一个完整的通知。

您的实施存在问题：

您对自定义 Observable 的实现是错误的。当你new创建一个 Observable 时，你必须将一个subscribe函数传递给它constructor，它有一个observer作为 arg 的函数。这observer有类似next,error和complete之类的方法，这些方法会在该 observable 的生命周期中的那些特定实例处被调用。

您还应该公开一个Subscription具有unsubscribe方法的对象，然后消费者可以使用该方法进行任何清理。

以下是它的一般实现方式：

const yourCustomObservable = new Observable((observer) => {
  observer.next("This pushes new value to the consumer");
  observer.error("This pushes an error to the consumer");
  observer.complete();

  return function unsubscribe() {
    // When the consumer unsubscribes, clean up data ready for next subscription.
  };
});

对于您的特定用例，您可以使用：

new Observable(...)：

import { Observable } from 'rxjs';
...
someService.getMethod().pipe(
  ...
  catchError((e) => {
    // some operation
    return new Observable(observer => observer.next(false));
  })
)

Observable.create：

import { Observable } from 'rxjs';
...
someService.getMethod().pipe(
  ...
  catchError((e) => {
    // some operation
    return Observable.create(observer => observer.next(false));
  })
)

of：

import { of } from 'rxjs';
...
someService.getMethod().pipe(
  ...
  catchError((e) => {
    // some operation
    return of(false);
  })
)

from：

import { from } from 'rxjs';
...
someService.getMethod().pipe(
  ...
  catchError((e) => {
    // some operation
    return from([false]);
  })
)

查看此示例 StackBlitz以获取参考。

什么时候用什么？

new Observable(...)或Observable.create(...)为您提供更精细的控制，您可以在其中定义自己的subscribe功能并在其中做任何您想做的事情。因此，您可能希望使用它来实现通常无法static使用Observable. 但是，对于像您这样的简单用例，使用Observable.oforObservable.from就足够了。

推荐阅读