Как подписаться на Observable и получить данные из потока?

Что такое Observable и зачем на него подписываться?

Observable — это ключевая концепция библиотеки RxJS, представляющая поток данных, который может асинхронно отправлять значения во времени. В отличие от Promise, который обрабатывает одно значение, Observable может передавать множество значений, а также сигнализировать об ошибке или завершении. Подписка на Observable позволяет начать получать эти данные и реагировать на них.

Как работает подписка?

Для подписки используется метод subscribe(), который принимает объект с тремя опциональными методами: next — вызывается при каждом новом значении, error — при возникновении ошибки, complete — когда поток завершился. Подписка возвращает объект Subscription, который позволяет отменить подписку и освободить ресурсы.

Пример кода

import { Observable } from 'rxjs';

const observable = new Observable(subscriber => {
  subscriber.next('Первое значение');
  subscriber.next('Второе значение');
  setTimeout(() => {
    subscriber.next('Третье значение');
    subscriber.complete();
  }, 1000);
});

const subscription = observable.subscribe({
  next: value => console.log('Получено:', value),
  error: err => console.error('Ошибка:', err),
  complete: () => console.log('Поток завершён')
});

// Отмена подписки через 2 секунды
setTimeout(() => subscription.unsubscribe(), 2000);

Где применяется

Observable широко используется в Angular для работы с HTTP-запросами, событиями, формами и состоянием приложения. Также применяется в React через библиотеки типа RxJS для управления сложными асинхронными потоками.

Вывод: Подписка на Observable — основной способ получения данных из асинхронных потоков. Используйте subscribe() для обработки значений, ошибок и завершения, и не забывайте отписываться для предотвращения утечек памяти.