Kombinations-Operatoren (Pipeable Operators)

RxJS-Kombinations-Operatoren (Combination) sind leistungsstarke Werkzeuge, um mehrere Observables zu kombinieren und neue Streams zu erstellen.

IMPORTANT

Diese Seite behandelt Pipeable Operators (Form für Verwendung innerhalb von Pipelines).

Für Creation Functions (Form zur Erstellung eines neuen Observables aus mehreren Observables) siehe Kapitel 3 Creation Functions.

Creation Functions vs Pipeable Operators

Funktionen im Zusammenhang mit Kombinationen werden in zwei Formen bereitgestellt.

Creation Functions (erklärt in Kapitel 3)

Nimmt mehrere Observables als Argumente und erstellt ein neues Observable.

import { concat, merge, combineLatest, zip, race, forkJoin } from 'rxjs';

// Verwendung als Creation Function
const combined$ = concat(obs1$, obs2$, obs3$);
const merged$ = merge(source1$, source2$);

Details siehe Creation Functions.

Pipeable Operators (auf dieser Seite erklärt)

Verwendung innerhalb von .pipe() für vorhandene Observables.

import { concatWith, mergeWith, combineLatestWith } from 'rxjs';

// Verwendung als Pipeable Operator
const result$ = source$.pipe(
  map(x => x * 2),
  concatWith(other$),
  filter(x => x > 10)
);

Pipeable Operators Liste

◾ Auf dieser Seite behandelte Operatoren

Operator	Beschreibung
withLatestFrom	Kombiniert die neuesten Werte anderer Streams entsprechend der Ausgabe des Haupt-Observables
mergeAll	Flacht Higher-order Observables parallel ab
concatAll	Flacht Higher-order Observables sequenziell ab
switchAll	Wechselt zum neuesten Higher-order Observable
exhaustAll	Ignoriert neue Higher-order Observables während der Ausführung
combineLatestAll	Kombiniert die neuesten Werte aller internen Observables
zipAll	Paart entsprechende Werte jedes internen Observables

◾ Als Creation Functions bereitgestellt

Die folgenden werden hauptsächlich als Creation Functions verwendet (siehe Kapitel 3).

Function	Beschreibung	Pipeable-Version
concat	Kombiniert in Reihenfolge	concatWith (RxJS 7+)
merge	Parallele Kombination	mergeWith (RxJS 7+)
combineLatest	Kombiniert neueste Werte	combineLatestWith (RxJS 7+)
zip	Paart entsprechende Werte	zipWith (RxJS 7+)
race	Verwendet den schnellsten Stream	raceWith (RxJS 7+)
forkJoin	Wartet auf Abschluss aller	(Keine Pipeable-Version)

Für weitere praktische Lernzwecke

Beispiele für reale Szenarien mit Kombinations-Operatoren werden in Praktische Anwendungsfälle ausführlich vorgestellt.