Wie kann ich Beobachten in RxJS

Sagen wir, wir haben ein Beobachtbaren:

var observable = Rx.Observable
    .fromEvent(document.getElementById('emitter'), 'click');

Wie kann ich es machen Komplette (was löst onComplete Ereignis für alle abonnierten Beobachter) ?

InformationsquelleAutor ulfryk | 2015-12-04
  1. 26

    In dieser heutigen form nicht. Ihre beobachtbar ist abgeleitet aus einer Quelle, die nicht abgeschlossen, es kann also nicht selbst abgeschlossen. Was Sie tun können, zu erweitern, um diese Quelle mit einem Abschluss Bedingung. Dies würde die Arbeit wie :

    var end$ = new Rx.Subject();
var observable = Rx.Observable
    .fromEvent(document.getElementById('emitter'), 'click')
    .takeUntil(end$);

    Wenn Sie wollen, um am Ende observable Sie tun end$.onNext("anything you want here");. Das ist in dem Fall das beenden-Ereignis wird durch Sie generiert wird. Wenn dies ist eine weitere Quelle generieren das Ereignis (Tastendruck, etc.) anschließend können Sie direkt eine observable abgeleitet aus dieser Quelle als argument takeUntil.

    Dokumentation:

    • Dies scheint potenzielle Gefahr von Speicherlecks im browser-app. Es scheint, dass es eine unendliche Zahl von Beobachtern verbunden mit der HTML-Elemente bereits entfernt aus Bereich. Es kann verhindern, dass GC von der Beseitigung dieser Elemente, und viele andere refs aus der Erinnerung...
    • ?? Ich glaube nicht, Folgen Sie Ihnen. Was ist 'das'? In jedem Fall, die onCompleted - handler ausgelöst, die für alle Beobachter, die das, was Sie gefragt. Über Speicher-Lecks, wenn der Letzte Beobachter hat sich abgemeldet aus dem beobachtbaren erstellt von fromEvent, den Ereignis-listener angelegt wurde, entfernt.
    • "was wird der Auslöser onComplete-event für alle abonnierten Beobachter" ist die zweite weitere Teil meiner Frage. Was ich brauche, zu erreichen, ist das entfernen von Ereignis-listener. Die komplette Fertigstellung der Beobachtbaren also ich kann entfernen Sie alle alten Verweise, wenn ich nicht hören für event mehr.
    • Das ist genau das, was passieren soll. Versuchen Sie den code und sehen, ob es funktioniert zuerst.
    • > Über Speicher-Lecks, wenn der Letzte Beobachter hat sich abgemeldet aus dem beobachtbaren erstellt von fromEvent, den Ereignis-listener angelegt wurde, entfernt. Oh - das ist, was macht Ihre Antwort wirklich hilfreich. Thx 😉
    • Ist das immer noch ein geeigneter Ansatz für dieses problem? Ich versuche zu kommen mit ein Weg, um eine cancel-Tokens zum Abbrechen, mehrere observablen auf einen "Abbrechen" - Methode ausgeübt haben.
    • stellen Sie eine Frage in SO mit so viel detail wie möglich

    InformationsquelleAutor user3743222
  2. 3

    Was für mich gearbeitet wird unter Verwendung der nehmen() Betreiber. Es wird Feuer die komplette callback nach x Anzahl der Ereignisse. Also durch die übergabe 1, wird es nach dem ersten Ereignis.

    Typoskript:

    private preloadImage(url: string): Observable<Event> {
    let img = new Image();
    let imageSource = Observable.fromEvent(img, "load");

    img.src = url;

    return imageSource.take(1);
}
    • first() kann anstelle von verwendet werden take(1)
    InformationsquelleAutor Tomas Klingen
  3. 1

    Ich denke was du suchst ist die dispose() Methode.

    aus: https://github.com/Reactive-Extensions/RxJS/blob/master/doc/gettingstarted/creating.md#cold-vs-hot-observables

    Beachten Sie, dass die subscribe-Methode gibt ein Einweg, so dass Sie Abmelden, um eine Sequenz und entsorgen Sie ihn einfach. Beim aufrufen der dispose-Methode auf den beobachtbaren Sequenz, der Beobachter wird die Wiedergabe beenden, um die beobachtbaren Daten zur Verfügung. Normalerweise, Sie müssen nicht explizit nennen, verfügen, es sei denn, Sie müssen sich Abmelden früh, oder wenn die Quelle beobachtbaren Sequenz hat eine längere Lebensdauer als die Beobachter. Abonnements in Rx sind entworfen für fire-and-forget-Szenarien ohne die Verwendung eines finalizers. Beachten Sie, dass das Standardverhalten des Beobachtbaren Betreiber entsorgen Sie das Abonnement so bald wie möglich (ich.e, wenn eine onCompleted oder onError-Nachrichten veröffentlicht wird). Zum Beispiel wird der code abonnieren Sie x, um die beiden Sequenzen a und b. Wenn einer einen Fehler löst, x wird sofort gekündigt werden aus b.

    • wenn die Frage gestellt: wie man sich Abmelden kann eine beobachtbare ein click-listener dann diese Antwort gelten würde. Aber die Frage, wie "komplett" ein beobachtbares$ -- laut diesem stackoverflow.com/a/52198997/3136861 durch @dK- Calling unsubscribe() itself does not call complete method
    InformationsquelleAutor Aiko Mastboom
Schreibe einen Kommentar