返回一个空的 Observable

Question

函数more() 应该从get 请求中返回Observable

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 is not defined 上收到错误，如何返回一个空的 Observable？

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

Answer 1

使用 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 完成了 observable，因此它不会在您的流中触发 next，而只会完成。因此，例如，如果您有 tap，它们可能无法如您所愿地触发（请参见下面的示例）。

而of({}) 创建一个Observable 并发出值为{} 的next，然后完成Observable。

例如：

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 2

对于打字稿，您可以像这样指定空可观察对象的通用参数：

import 'rxjs/add/observable/empty' 

Observable.empty<Response>();

Answer 3

RxJS6（未安装兼容包）

现在有一个 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 4

在我使用 Angular2 和 rxjs 的情况下，它适用于：

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

Answer 5

创建 Empty Observable 的几种方法：

它们只是在您将如何进一步使用它方面有所不同（它将在之后发出什么事件：next、complete 或 do nothing）例如：

• Observable.never() - 不发出任何事件并且永不结束。
• Observable.empty() - 只发出 complete。
• Observable.of({}) - 发出 next 和 complete（作为示例传递的空对象字面量）。

根据您的确切需求使用它）

Answer 6

是的，有Empty运营商

Rx.Observable.empty();

对于打字稿，你可以使用from:

Rx.Observable<Response>.from([])

Answer 7

你可以返回 Observable.of(empty_variable)，例如

Observable.of('');

// or
Observable.of({});

// etc

Answer 8

由于所有答案都已过时，我将在此处发布最新答案

在 RXJS >= 6

import { EMPTY } from 'rxjs'
return EMPTY;

Answer 9

或者你也可以试试ignoreElements()

Answer 10

RxJS 6

你也可以使用下面的函数：

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

导入后：

import {from} from 'rxjs';

Answer 11

带着类似的问题来到这里，上面的方法对我不起作用："rxjs": "^6.0.0"，为了生成一个不发出我需要做的数据的可观察对象：

import {Observable,empty} from 'rxjs';
class ActivatedRouteStub {
  params: Observable<any> = empty();
}

Answer 12

试试这个

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();

Answer 13

你可以用所有不同的方式返回空的 observable，但挑战是用预期的类型返回它 - 下面是创建一个空的 observable 类型的方法 -

intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
    
return next.handle(this.setHeaders(req))
            .pipe(
                catchError((error: HttpErrorResponse) => {
        // you write your logic and return empty response if required
        return new Observable<HttpEvent<any>>();
            }));
    }

Answer 14

返回空 observable 的不同方式：

1. Observable.from({});
2. Observable.of({});
3. 空

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