Retourne un Observable vide

Question

La fonction more() est censé retourner un Observable à partir d'une requête 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();
    });
  };
}

Dans ce cas, je ne peux faire une demande que si hasMore() est vrai, sinon je reçois une erreur sur subscribe() fonction subscribe is not defined Comment puis-je retourner un Observable vide ?

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

Mise à jour

Dans RXJS 6

import { EMPTY } from 'rxjs'
return EMPTY;

Answer 1

Avec la nouvelle syntaxe de RxJS 5.5+, cela devient comme suit :

// 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({});

Juste une chose à garder à l'esprit, EMPTY complète l'observable, donc il ne déclenchera pas next dans votre flux, mais ne fait que compléter. Donc si vous avez, par exemple, tap il se peut qu'ils ne se déclenchent pas comme vous le souhaitez (voir un exemple ci-dessous).

Considérant que of({}) crée un Observable et émet le suivant avec une valeur de {} et ensuite il complète le Observable .

Par exemple :

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

Pour le script de type, vous pouvez spécifier le paramètre générique de votre observable vide comme ceci :

import 'rxjs/add/observable/empty' 

Observable.empty<Response>();

Answer 3

RxJS6 (sans paquet de compatibilité installé)

Il y a maintenant un EMPTY constante et une empty fonction.

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

  var delay = empty().pipe(delay(1000));     
  var delay2 = EMPTY.pipe(delay(1000));

Observable.empty() n'existe plus.

Answer 4

Dans mon cas, avec Angular2 et rxjs, cela a fonctionné avec :

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

Answer 5

Oui, il y en a un. Vide opérateur

Rx.Observable.empty();

Pour le script, vous pouvez utiliser from :

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