Какво е observable?

Observable е същност, която представлява поток от данни или събития, който може да бъде асинхронен. Източниците, които могат да бъдат наблюдавани, могат да излъчват стойности за определен период от време, а абонатите (Subscribers или Observers) могат да реагират на тези стойности, когато се появят.

Ключови концепции:

• Observable (Наблюдаван източник): Източник на данни или събития.
• Observer (Наблюдател): Обект с методи за реакция на събития от Observable (next, error, complete).
  • next: Получаване на следващата стойност.
  • error: Възникване на грешка.
  • complete: Потокът от данни приключва.
• Subscription (Абонамент): Връзка между Observable и Observer. Създава се при извикване на метода subscribe върху Observable. Позволява на Observer да получава стойности и да управлява жизнения цикъл на абонамента (например, да се отпише, за да се избегнат течове на памет).
• Operators (Оператори): Функции за преобразуване, комбиниране и управление на потоците Observable. Примери: map, filter, mergeMap, debounceTime.

За разлика от Promises, Observable могат да излъчват множество стойности с течение на времето, представлявайки потоци от данни, а не еднократно асинхронно събитие.

Пример за използване в RxJS (популярна библиотека за реактивно програмиране):

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

// Създаване на Observable от масив
const source = new Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.complete(); // Завършване на потока
});

// Абониране и използване на оператора
const subscription = source.pipe(
  map(value => value * 2) // Операторът map удвоява всяка стойност
).subscribe({
  next: value => console.log(value), // Получаване на стойностите: 2, 4, 6
  error: err => console.error(err), // Обработка на грешки
  complete: () => console.log('Complete!') // Завършване
});

Основни предимства:

• Реактивно програмиране: удобен контрол върху асинхронните потоци от данни.
• Компонентност: възможност за лесно комбиниране и трансформиране на потоци с помощта на оператори.
• Управление на жизнения цикъл: абонаментът позволява явно управление на получаването на данни и предотвратяване на течове на памет.