Heim > Artikel > Web-Frontend > Detaillierte Erläuterung der Verwendung von Rxjs
Dieses Mal erkläre ich Ihnen ausführlich, welche Vorsichtsmaßnahmen bei der Verwendung von Rxjs zu beachten sind.
var observable = Rx.Observable.create(function subscribe(observer) { observer.next(1); observer.next(2); observer.next(3); observer.complete(); observer.next(4); // Is not delivered because it would violate the contract});Eine gute Möglichkeit ist die Verwendung von try/catch. Die Anweisung wird umbrochen die Benachrichtigungsanweisung und sendet eine Fehlerbenachrichtigung, wenn eine Ausnahme abgefangen wird.
var observable = Rx.Observable.create(function subscribe(observer) {try { observer.next(1); observer.next(2); observer.next(3); observer.complete(); } catch (err) { observer.error(err); // delivers an error if it caught one} });Unsubscribe unsubscribe()Da die Ausführung beobachtbarer Objekte unendlich sein kann (kontinuierlich weiter), möchten Beobachter dies oft in einer begrenzten Zeit tun. Die Ausführung wird also innerhalb von begrenzter Zeit beendet Wir benötigen eine API, um die Ausführung abzubrechen. var observable = Rx.Observable.from([10, 20, 30]);var subscription = observable.subscribe(x => console.log(x));// Später:subscription.unsubscribe ();
var observer={next:x=>console.log('Observer got a next value: ' + x),error: err => console.error('Observer got an error: ' + err),complete: () => console.log('Observer got a complete notification') }Ein Beobachter ist nur ein Objekt, das aus einem Array von drei Rückruffunktionen besteht
Jede Rückruffunktion entspricht der Benachrichtigung des beobachtbarer Objekttyp.
AbonnementAbonnementobjekte können auch zusammen platziert werden, sodass der Aufruf von unsubscribe() für ein Abonnementobjekt mehrere Abonnements kündigen kann. Die Methode lautet: „Hinzufügen“ eines Abonnements zu einem anderen Abonnement.var observable1 = Rx.Observable.interval(400);var observable2 = Rx.Observable.interval(300);var subscription = observable1.subscribe(x => console.log('first: ' + x));var childSubscription = observable2.subscribe(x => console.log('second: ' + x)); subscription.add(childSubscription); setTimeout(() => {// Unsubscribes BOTH subscription and childSubscriptionsubscription.unsubscribe(); }, 1000);Nach der Ausführung können wir in die Konsole gelangen:
second: 0 first: 0 second: 1 first: 1 second: 2Das Abonnement verfügt auch über eine Methode „remove(otherSubscription)“, mit der das durch „add“ hinzugefügte Abonnement storniert werden kann . Ich glaube, dass Sie die Methode beherrschen, nachdem Sie den Fall in diesem Artikel gelesen haben. Weitere spannende Informationen finden Sie auf der chinesischen PHP-Website
Andere verwandte Artikel!
Verwandte Lektüre:Detaillierte Erläuterung der Verwendung der js-xlsx-Toolbibliothek xlsxUtils
Integration täglicher gemeinsamer Funktionen von JS
Das obige ist der detaillierte Inhalt vonDetaillierte Erläuterung der Verwendung von Rxjs. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!