返回一个空的可观察

Question

函数more（）应该从get请求返回一个可观察的

export class Collection {
  public more = (): Observable<Response> => {
    if (this.hasMore()) {
      return this.fetch();
    } else {
      // return empty observable
    }
  };

  private fetch = (): Observable<Response> => {
    return this.http.get("some-url").map((res) => {
      return res.json();
    });
  };
}

在这种情况下，我只能在hasMore（）为真时执行请求，否则我在subscribe（）函数subscribe未定义时出错，我如何返回空的可观测值？

this.collection.more().subscribe(
  (res) => {
    console.log(res);
  }, (err) => {
    console.log(err);
  }
);

在RXJS 6中

import { EMPTY } from 'rxjs'
return EMPTY; 




Answer 1

现在有一个EMPTY常量和一个EMPTY函数。

  import { Observable, empty, EMPTY, of } from 'rxjs';

  //This is now deprecated
  var delay = empty().pipe(delay(1000));     
  var delay2 = EMPTY.pipe(delay(1000));

Observable.empty（）不存在了。

Answer 2

匿名用户

使用RxJS 5.5的新语法，如下所示：

// RxJS 6
import { EMPTY, empty, of } from "rxjs";

// rxjs 5.5+ (<6)
import { empty } from "rxjs/observable/empty";
import { of } from "rxjs/observable/of";

empty(); // deprecated use EMPTY
EMPTY;
of({});

需要记住的一件事是，EMPTY完成了可观察对象，因此它不会触发流中的next，只会完成。因此，如果您有，例如，点击，他们可能不会得到您想要的触发器（参见下面的示例）。

而（{}）的创建一个可观察的，并发出下一个值为{}，然后完成可观察的。

例如。：

EMPTY.pipe(
    tap(() => console.warn("i will not reach here, as i am complete"))
).subscribe();

of({}).pipe(
    tap(() => console.warn("i will reach here and complete"))
).subscribe();

Answer 3

对于typescript，您可以指定空可观察对象的通用参数，如下所示：

import 'rxjs/add/observable/empty' 

Observable.empty<Response>();