Erstellen Sie ein one-time-Abo

Brauche ich zum erstellen eines Abonnements für einen Observable wird sofort entsorgt, wenn er zuerst genannt.

Gibt es so etwas wie:

observable.subscribeOnce(func);

Meine, ich bin ein Abonnement erstellen, die in einer express route-handler und das Abonnement wird mehrfach aufgerufen wird, pro request.

InformationsquelleAutor Berkeley Martinez | 2015-01-18

rxjs

232

Nicht 100% sicher über das, was Sie brauchen, aber wenn Sie nur wollen, zu beobachten, der erste Wert, dann verwenden Sie entweder first() oder take(1):
```
observable.first().subscribe(func);
```
Hinweis: .take(1) und .first() beide Abmelden automatisch, wenn Ihre Bedingung erfüllt ist

Update von RxJS 5.5+

Kommentar von Coderer.
```
import { first } from 'rxjs/operators';

observable.pipe(
            first()
          )
          .subscribe(func);
```
Hier ist, warum
- Wird das Abo automatisch bereinigt nach?
- Ja, es funktioniert. Nehmen und die ersten beiden Abmelden, wenn Ihre Bedingung erfüllt ist.
- Warum nicht in der Dokumentation sagen, dass es automatisch über die Abo?
- Es ist eine Allgemeine RxJS Regel, dass die Abonnements werden entsorgt, wenn eine beobachtbare stream endet. Das bedeutet, dass jeder operator, der "verkürzt" einen stream (oder verwandelt es in eine andere Art von Strom) Abmelden von der Quelle streamen, wenn Ihre operation abgeschlossen ist. Ich bin mir nicht sicher, wo oder ob dies in der Dokumentation erwähnt wird.
- was ist, wenn der erste Wert wird nie zurückgegeben, wird es dazu führen, dass Speicher-Leckage? Ist es am besten, um auch ein unmount-Funktion, Abmelden/entsorgen der observable?
- ja, wenn Sie abonnieren, wenn eine Komponente montiert ist, dann wollen Sie sicher sein, Abmelden, wenn die Komponente ausgehängt, um zu verhindern, dass Ressourcen-Lecks
- aus irgendeinem seltsamen Grund, den ersten() funktioniert nicht für mich, aber nehmen Sie(1) keine ...
- first? sicherlich last oder pop ist das, was unser Gehirn hören wollen
- Wenn jemand kommt, um diese im Jahr 2018, die Sie tatsächlich wollen observable.pipe(first()).subscribe(func), wo first kommt aus rxjs/operators.
- Was ist der Unterschied?
- hier ist der Grund, warum
InformationsquelleAutor Brandon
26

RxJS hat einige der besten Dokumentation, die ich jemals über gekommen sind. Nach der Balg link gelangen Sie zu einem überaus hilfreichen Tabelle mapping Anwendungsfälle zu den Operatoren. Zum Beispiel, unter der "ich möchte den ersten Wert" use case sind drei Operatoren: first, firstOrDefault, und sample.

Hinweis, wenn eine beobachtbare Sequenz abgeschlossen mit keine Benachrichtigungen, dann die first Betreiber benachrichtigt Abonnenten mit einem Fehler, während die firstOrDefault Betreiber stellt einen Standardwert für die Abonnenten.

Betreiber use-case-lookup

InformationsquelleAutor DetweilerRyan

Ergänzen @Brandon Antwort, mit first() oder ähnliches ist auch wichtig für die Aktualisierung einer BehaviorSubject basierend auf seiner Observable. Beispielsweise (ungetestet):

var subject = new BehaviorSubject({1:'apple',2:'banana'});
var observable = subject.asObservable();

observable
  .pipe(
    first(), //<-- Ensures no stack overflow
    flatMap(function(obj) {
      obj[3] = 'pear';
      return of(obj);
    })
  )
  .subscribe(function(obj) {
    subject.next(obj);
  });

InformationsquelleAutor Andy

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.

Update von RxJS 5.5+