Что такое pipe в RxJS и как его применять?

Что такое pipe в RxJS?

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

Как это работает?

Каждый оператор — это функция, которая принимает Observable и возвращает новый Observable с измененными данными. Pipe просто вызывает эти функции по порядку, передавая результат предыдущей в следующую.

Пример кода

import { of } from 'rxjs';
import { map, filter } from 'rxjs/operators';

const source$ = of(1, 2, 3, 4, 5);

const result$ = source$.pipe(
  filter(x => x % 2 === 0), // Оставляем только четные
  map(x => x * 10)          // Умножаем на 10
);

result$.subscribe(console.log); // Вывод: 20, 40

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

Pipe используется везде, где нужно обрабатывать асинхронные потоки данных: в Angular для работы с HTTP-запросами, формами, событиями. Он помогает создавать чистые и тестируемые цепочки обработки.

Вывод

Pipe — это стандартный способ композиции операторов в RxJS, который делает код декларативным и легко читаемым. Его стоит применять всегда при работе с Observable для улучшения структуры и переиспользования логики.