Наблюдаемые являются неотъемлемой частью реактивного программирования и асинхронного JavaScript. Они представляют потоки данных с течением времени, позволяя разработчикам выполнять асинхронные операции более элегантным и эффективным способом. В этой статье блога мы рассмотрим различные методы работы с Observables, сопровождаемые примерами кода, иллюстрирующими их использование.

1. Подписаться:
   Метод subscribeиспользуется для прослушивания значений, излучаемых Observable. В качестве аргументов он принимает объект-наблюдатель или функции обратного вызова для обработки выдаваемых значений, ошибок и сигналов завершения.

const observable = new Observable((observer) => {
  observer.next('Hello');
  observer.next('World');
  observer.complete();
});
observable.subscribe({
  next: (value) => console.log(value),
  error: (error) => console.error(error),
  complete: () => console.log('Completed')
});

1. Канал:
   Метод pipeпозволяет преобразовывать, фильтровать или комбинировать наблюдаемые объекты с помощью различных операторов. Операторы – это функции, которые можно объединить в цепочку для создания конвейера обработки данных.

import { of } from 'rxjs';
import { map, filter } from 'rxjs/operators';
const source = of(1, 2, 3, 4, 5);
source.pipe(
  filter((value) => value % 2 === 0),
  map((value) => value * 2)
).subscribe((result) => console.log(result));

1. Карта:
   Оператор mapпреобразует значения, выдаваемые Observable, с помощью функции проекции.

import { from } from 'rxjs';
import { map } from 'rxjs/operators';
const source = from(['apple', 'banana', 'cherry']);
source.pipe(
  map((value) => value.toUpperCase())
).subscribe((result) => console.log(result));

1. Фильтр:
   Оператор filterвыборочно выдает значения из Observable на основе условия.

import { of } from 'rxjs';
import { filter } from 'rxjs/operators';
const source = of(1, 2, 3, 4, 5);
source.pipe(
  filter((value) => value > 2)
).subscribe((result) => console.log(result));

1. Объединение:
   Оператор mergeобъединяет несколько Observable в один Observable, который одновременно генерирует значения из всех исходных Observable.

import { interval } from 'rxjs';
import { merge } from 'rxjs/operators';
const source1 = interval(1000);
const source2 = interval(2000);
merge(source1, source2).subscribe((result) => console.log(result));

1. Concat:
   Оператор concatобъединяет несколько Observable, последовательно выдавая значения из каждого источника Observable.

import { of, concat } from 'rxjs';
const source1 = of(1, 2, 3);
const source2 = of(4, 5, 6);
concat(source1, source2).subscribe((result) => console.log(result));

Observables предоставляют мощный и гибкий способ обработки асинхронных операций в JavaScript. В этой статье мы рассмотрели некоторые важные методы работы с Observables, включая subscribe, pipe, map, filter., mergeи concat. Освоив эти методы, разработчики смогут использовать весь потенциал Observables и реактивного программирования в своих приложениях.

Не забывайте следить за более продвинутыми концепциями и методами, связанными с Observables и реактивным программированием.