Zurück ein leerer Beobachten

Die Funktion more() soll, um eine Observable aus einer get-Anfrage

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

In diesem Fall kann ich nur tun, wenn hasMore() wahr ist, sonst bekomme ich eine Fehlermeldung auf subscribe() Funktion subscribe is not defined, wie kann ich wieder eine leere beobachtbar?

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

Update

In RXJS 6

import { EMPTY } from 'rxjs'

return EMPTY;
InformationsquelleAutor Murhaf Sousli | 2016-07-24
  1. 110

    Für typescript können Sie angeben, generic param deiner leeren beobachten, wie diese: 

    import 'rxjs/add/observable/empty' 

Observable.empty<Response>();
    • Dies sollte jetzt import "EmptyObservable" from "rxjs/observable/EmptyObservable";, dann new EmptyObservable<Response>();.
    InformationsquelleAutor Andrei Petrov
  2. 53

    Mit der neuen syntax z.B. rxjs 5.5+, wird dies wie folgt:

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

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

empty();
of({});

    Nur eine Sache im Auge zu behalten, empty() rundet das beobachtbare, so es wird nicht ausgelöst next in Ihrem stream, nur beendet! Also, wenn Sie tap zum Beispiel, dass Sie möglicherweise nicht auslösen, wie Sie wollen (siehe Beispiel unten).

    in der Erwägung, dass of({}) schafft eine beobachtbare und strahlt weiter mit einem Wert von {} und dann schließt es die beobachtbar.

    z.B.

    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();
    • Sie können auch einfach tun of() ich glaube, dass
    • of('foo') tut emittieren und vollständig beobachtbaren sofort. rxviz.com/v/0oqMVW1o
    • ja du hast Recht, mein schlechtes für die Verwendung take(1) entfernt für eine bessere Antwort. @MatthijsWessels, ja und Nein, gerade getestet jetzt und wenn Sie of() zurück vervollständigen beobachten, ohne dass next
    InformationsquelleAutor Stephen Lautier
  3. 36

    In meinem Fall mit Angular2 und rxjs, es arbeiteten mit:

    import {EmptyObservable} from 'rxjs/observable/EmptyObservable';
...
return new EmptyObservable();
...
    InformationsquelleAutor Marcel Tinner
  4. 31

    RxJS6 (ohne Kompatibilitäts-Paket installiert)

    Gibt es jetzt einen EMPTY ständige und eine empty Funktion.

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

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

    Observable.empty() existiert nicht mehr.

    • Update-Anleitung: github.com/ReactiveX/rxjs/blob/master/MIGRATION.md
    • Wenn Sie einen Konflikt wie ein empty() Funktion schon kann man sagen import { empty as rxEmpty } oder import { empty as _empty } tun, und dann rxEmpty() oder _empty(). Das ist natürlich ein ziemlich non-standard, was zu tun und ich bin eigentlich nicht empfehlen, aber ich bin sicher, ich bin nicht die einzige, die überrascht war, RxJS denkt, es ist würdig Import Funktionen wie of und empty in meinem Namensraum!
    • Sie vorsichtig, wenn mit Kantigen, weil es auch import { EMPTY } from "@angular/core/src/render3/definition"; die ist komplett nicht das, was Sie wollen. Also, wenn Sie ungerade Fehler stellen Sie sicher, dass Sie nicht importieren, dass durch Fehler.
    InformationsquelleAutor Simon_Weaver
  5. 28

    Ja, es ist am Leer Betreiber

    Rx.Observable.empty();

    Zur Typoskript, können Sie from:

    Rx.Observable<Response>.from([])
    • Ich bin immer Rx.Observable<{}> ist nicht zuweisbar Observable<Response> habe ich versucht zu Rx.Observable<Response>.empty() aber es hat nicht funktioniert
    • Ich habe den code für typescript
    • Ich änderte den Rückgabetyp zu Observable<any> und es hat funktioniert, danke Kumpel.
    • Es sollte Rx.Observable.from([]) ohne <Response>. Sonst immer eine Fehlermeldung "Ausdruck erwartet".
    • Sie können auch Rx.Observable.of([]).
    • Ich bin nicht sicher, dies ist gleichwertig. In Observable.of([]) gibt es einen Wert emittiert ( []) und dann der stream abgeschlossen ist. Mit Observable.from([]), wird kein Wert ausgegeben, der stream sofort abgeschlossen.
    • Die Dokumentation besagt, dass es besser ist, verwenden Sie die import {EMPTY} from 'rxjs' (besser als die empty() - Methode). Ich gehe davon aus, dass es ein Speicher-Sache (d.h. Wiederverwendung der gleichen leere Werte ist besser als die Schaffung mehrere leere Objekte)

    InformationsquelleAutor Toan Nguyen
  6. 14

    Mehrere Möglichkeiten zum erstellen einer Leeren Beobachten:

    Sie unterscheiden sich gerade, wie Sie gehen zu verwenden, weitere (welche Ereignisse er aus nach: next, complete oder do nothing) z.B.:

    • Observable.never() - strahlt keine Veranstaltungen und endet nie.
    • Observable.empty() - emittiert nur complete.
    • Observable.of({}) - strahlt sowohl next und complete (Leere object-literal übergeben als Beispiel).

    Verwenden Sie es auf Ihre genauen Bedürfnisse)

    InformationsquelleAutor Andrii Verbytskyi
  7. 11

    Können Sie zurück zu Beobachten.der(empty_variable), zum Beispiel

    Observable.of('');

//or
Observable.of({});

//etc
    InformationsquelleAutor Chybie
  8. 2

    Oder Sie können versuchen ignoreElements() sowie

    InformationsquelleAutor Tuong Le
  9. 0

    Versuchen, diese

    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();
    InformationsquelleAutor Jorawar Singh
  10. 0

    RxJS 6

    können Sie auch aus der Funktion, wie unten:

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

    nach dem importieren:

    import {from} from 'rxjs';
    • Dadurch wird eine Beobachtbare vorsehen, dass ein element (eine leere Zeichenkette), so dass es nicht mehr wie eine richtige Antwort auf diese spezielle Frage.
    InformationsquelleAutor Nour
  11. 0

    Kam hier mit einer ähnlichen Frage, die oben nicht für mich arbeiten, in: "rxjs": "^6.0.0", um zu generieren, eine beobachtbare, das strahlt keine Daten, die ich brauchte, zu tun:

    import {Observable,empty} from 'rxjs';
class ActivatedRouteStub {
  params: Observable<any> = empty();
}
    • funktioniert im Winkel 6+
    InformationsquelleAutor Callat
Schreibe einen Kommentar