Co je to observable?

Observable je entita, která představuje proud dat nebo událostí, jež může být asynchronní. Zdrojové objekty Observable mohou emitovat hodnoty v určitém časovém období a předplatitelé (Subscribers nebo Observers) na tyto hodnoty mohou reagovat, jakmile se objeví.

Klíčové koncepty:

• Observable (Pozorovatelný zdroj): Zdroj dat nebo událostí.
• Observer (Pozorovatel): Objekt s metodami pro reakci na události Observable (next, error, complete).
  • next: Přijímání další hodnoty.
  • error: Dojde k chybě.
  • complete: Proud dat končí.
• Subscription (Odběr): Spojení mezi Observable a Observer. Odběr se vytváří voláním metody subscribe na Observable. Umožňuje Observerovi přijímat hodnoty a řídit životní cyklus odběru (například odhlášení, aby se zabránilo únikům paměti).
• Operators (Operátory): Funkce pro transformaci, kombinaci a správu proudů Observable. Příklady: map, filter, mergeMap, debounceTime.

Na rozdíl od Promise mohou Observable emitovat více hodnot v čase, což představuje datové proudy, nikoli jedinou asynchronní událost.

Příklad použití v RxJS (populární knihovna pro reaktivní programování):

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

// Vytvoření Observable z pole
const source = new Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.complete(); // Ukončení proudu
});

// Odběr a použití operátoru
const subscription = source.pipe(
  map(value => value * 2) // Operátor map zdvojnásobí každou hodnotu
).subscribe({
  next: value => console.log(value), // Přijímá hodnoty: 2, 4, 6
  error: err => console.error(err), // Zpracování chyb
  complete: () => console.log('Complete!') // Ukončení
});

Hlavní výhody:

• Reaktivní programování: pohodlné řízení asynchronních proudů dat.
• Komponovatelnost: možnost snadného kombinování a transformace proudů pomocí operátorů.
• Řízení životního cyklu: odběr umožňuje explicitně řídit příjem dat a předcházet únikům paměti.