Kas ir observable?

Observable ir objekts, kas pārstāv datu vai notikumu plūsmu, kas var būt asinhroni. Novērojamie avoti var emitēt vērtības noteiktā laika periodā, un abonenti (Subscribers vai Observers) var reaģēt uz šīm vērtībām to parādīšanās laikā.

Galvenās koncepcijas:

• Observable (Novērojams avots): Datu vai notikumu avots.
• Observer (Novērotājs): Objekts ar metodēm next, error, complete, kas reaģē uz Observable notikumiem:
  • next: Saņemt nākamo vērtību.
  • error: Notikusi kļūda.
  • complete: Datu plūsma ir pabeigta.
• Subscription (Abonēšana): Saistība starp Observable un Observer. Abonēšana tiek izveidota, izsaucot subscribe metodi uz Observable. Tā ļauj Observer saņemt vērtības un pārvaldīt abonēšanas dzīves ciklu.
• Operators (Operatori): Funkcijas, kas transformē, apvieno un pārvalda Observable plūsmas. Piemēri: map, filter, mergeMap, debounceTime.

Observable atšķirībā no Promises var emitēt daudz vērtību laika gaitā, pārstāvot datu plūsmu, nevis vienreizēju asinhronu notikumu.

Piemērs, izmantojot RxJS (populāra reaktīvas programmēšanas bibliotēka):

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

// Observable izveide no masīva
const source = new Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.complete(); // Pabeigt plūsmu
});

// Abonēšana un operatora izmantošana
const subscription = source.pipe(
  map(value => value * 2) // `map` operators dubulto katru vērtību
).subscribe({
  next: value => console.log(value), // Saņemtās vērtības: 2, 4, 6
  error: err => console.error(err), // Kļūdu apstrāde
  complete: () => console.log('Complete!') // Pabeigt
});

Galvenās priekšrocības:

• Reaktīva programmēšana: ērtas asinhrono datu plūsmu pārvaldība.
• Kompozīcija: viegli kombinēt un transformēt plūsmas ar operatoriem.
• Dzīves cikla pārvaldība: abonēšana ļauj skaidri kontrolēt datu saņemšanu un novērst atmiņas noplūdi.