Was ist ein Observable?

Observable ist eine Entität, die einen Daten- oder Ereignisstrom darstellt, der asynchron sein kann. Beobachtbare Quellen können Werte über einen bestimmten Zeitraum ausstrahlen, und Abonnenten (Subscribers oder Observers) können auf diese Werte reagieren, sobald sie erscheinen.

Schlüsselkonzepte:

• Observable (Beobachtbare Quelle): Daten- oder Ereignisquelle.
• Observer (Beobachter): Objekt mit Methoden, um auf Ereignisse des Observables zu reagieren (next, error, complete).
  • next: Erhalt des nächsten Wertes.
  • error: Es tritt ein Fehler auf.
  • complete: Der Datenstrom ist beendet.
• Subscription (Abonnement): Verbindung zwischen Observable und Observer. Das Abonnement wird beim Aufruf der Methode subscribe auf einem Observable erstellt. Es ermöglicht dem Observer, Werte zu empfangen und den Lebenszyklus des Abonnements zu verwalten (z.B. Abmeldung, um Speicherlecks zu vermeiden).
• Operators (Operatoren): Funktionen zur Transformation, Kombination und Steuerung von Observable-Streams. Beispiele: map, filter, mergeMap, debounceTime.

Im Gegensatz zu Promises können Observable mehrere Werte im Laufe der Zeit ausstrahlen, was Datenströme darstellt, anstatt eines einzelnen asynchronen Ereignisses.

Beispiel für die Verwendung in RxJS (eine beliebte Bibliothek für reaktive Programmierung):

import { Observable } from 'rxjs';
import { map } from 'rxjs/operators';

// Erstellen eines Observable aus einem Array
const source = new Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.complete(); // Beendet den Strom
});

// Abonnement und Verwendung des Operators
const subscription = source.pipe(
  map(value => value * 2) // Der map-Operator verdoppelt jeden Wert
).subscribe({
  next: value => console.log(value), // Erhält die Werte: 2, 4, 6
  error: err => console.error(err), // Fehlerbehandlung
  complete: () => console.log('Complete!') // Beendet
});

Hauptvorteile:

• Reaktive Programmierung: Bequeme Verwaltung asynchroner Datenströme.
• Komponierbarkeit: Möglichkeit, Ströme leicht mit Operatoren zu kombinieren und zu transformieren.
• Lebenszyklusmanagement: Das Abonnement ermöglicht eine explizite Steuerung des Datenempfangs und verhindert Speicherlecks.