返回一个空的Observable

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()为真，否则我得到一个错误订阅()函数订阅没有定义，我怎么能返回一个空的可观察对象?

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

当前回答

返回空可观察对象的不同方法:

Observable.from ({}); Observable.of ({}); 空

https://www.learnrxjs.io/learn-rxjs/operators/creation/empty

2021-12-23 19:58:08

其他回答

返回空可观察对象的不同方法:

Observable.from ({}); Observable.of ({}); 空

https://www.learnrxjs.io/learn-rxjs/operators/creation/empty

2021-12-23 19:58:08

试试这个

export class Collection{
public more (): Observable<Response> {
   if (this.hasMore()) {
     return this.fetch();
   }
   else{
     return this.returnEmpty(); 
   }            
  }
public returnEmpty(): any {
    let subscription = source.subscribe(
      function (x) {
       console.log('Next: %s', x);
    },
    function (err) {
       console.log('Error: %s', err);
    },
    function () {
       console.log('Completed');
    });
    }
  }
let source = Observable.empty();

2016-07-24 04:16:28

RxJS 6

你可以像下面这样使用also from函数:

return from<string>([""]);

导入后:

import {from} from 'rxjs';

2018-05-13 16:14:12

在我使用Angular2和rxjs的情况下，它与:

import {EmptyObservable} from 'rxjs/observable/EmptyObservable';
...
return new EmptyObservable();
...

2016-10-09 08:56:59

RxJS6(未安装兼容包)

现在有一个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()不再存在。

2018-05-05 19:17:59

返回一个空的Observable

推荐文章

最新文章

标签