Warum wird mein RXJS -Code beim Betrieb auf Streams nicht wirksam?

Häufig gestellte Fragen und Lösungen für den ungültigen RXJS -Streaming -Betrieb

Bei Verwendung von RXJs zum Verarbeiten von Datenflüssen begegnen Entwickler häufig Situationen, in denen die Betreiber nicht wie erwartet arbeiten können. In diesem Artikel wird ein typischer Fall analysiert, die Grundursache des Problems erläutert und Lösungen bereitgestellt.

Problem: Der Betrieb von sogar multiplizieren mit zwei Fehlern

Nehmen wir an, wir müssen eine Reihe von Zahlen verarbeiten, auch Nummern herausfiltern und mit 2. Code mit of Operator, filter und map multiplizieren. Der Code ist wie folgt:

 import {von} aus 'rxjs';
import {map, filter} aus 'rxjs/operatoren';

const Source $ = von ([1, 2, 3, 4, 5]);
Quelle $ .pipe (
  filter (item => item % 2 === 0),
  Karte (num => num * 2)
) .Subscribe (value => console.log (value));

Die erwarteten Ausgänge betragen 4 und 8 , das tatsächliche Ergebnis hat jedoch keine Ausgabe.

Analyse verursachen

Das Problem liegt in der Verwendung of Operators. of Operator emittiert die Eingabeparameter als Ganzes, anstatt jedes Element im Array getrennt zu übertragen. Daher ist der vom filter und map empfangene item das gesamte Array [1, 2, 3, 4, 5] und nicht eine einzige Zahl im Array. Das Urteil von item % 2 === 0 ist für das gesamte Array ungültig, wodurch filter alle Inhalte herausfiltert.

Lösung: Verwenden Sie den from Bediener vom Operator

Um dieses Problem zu lösen, sollte from Operator anstelle of Operators verwendet werden. from Operator das Array in einzelne Elemente teilt und gibt es nacheinander in die beobachtbare. Der geänderte Code lautet wie folgt:

 import {von} aus 'rxjs';
import {map, filter} aus 'rxjs/operatoren';

const Source $ = aus ([1, 2, 3, 4, 5]);
Quelle $ .pipe (
  filter (item => item % 2 === 0),
  Karte (num => num * 2)
) .Subscribe (value => console.log (value));

Jetzt verarbeitet filter und die map jede Zahl ordnungsgemäß, wobei die endgültigen Ausgaben 4 und 8 . Dies zeigt, wie wichtig es ist, den korrekten RXJS -Operator für die korrekte Verarbeitung von Datenflüssen auszuwählen.

Das obige ist der detaillierte Inhalt vonWarum wird mein RXJS -Code beim Betrieb auf Streams nicht wirksam?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!