RxJS. Переиспользуемые операторы

Существует возможность сгруппировать любые RxJS операторы для дальнейшего повторного использования.

Первый пример

import { of, pipe, range } from 'rxjs'; 
import { filter, map, reduce, take } from 'rxjs/operators';

const filterOutEvens = filter((x: number) => Boolean(x % 2));
const sum = reduce((acc, next) => acc + next, 0);
const doubleBy = x => map((value: number) => value * x);

const complicatedLogic = pipe(
  filterOutEvens,
  doubleBy(2),
  sum
);

range(0,10).pipe(complicatedLogic).subscribe(console.log); // 50

Stackblitz

Второй пример

import { pipe } from "rxjs";
import { debounceTime, distinctUntilChanged } from "rxjs/operators";

const debounceInput = pipe(
  debounceTime<string>(400),
  distinctUntilChanged()
);

valueChanges.pipe(debounceInput)

Третий пример

/**
 * Retry request when error occured
 * @param delayDuration - delay between requests
 * @param retryCount - request count
 */
export function retryRequestOnError<T>(
  retryCount: number = 5,
  delayDuration: number = 2000
): MonoTypeOperatorFunction<T> {
  return retryWhen(errors =>
    concat(
      errors.pipe(
        delay(delayDuration),
        take(retryCount)
      ),
      throwError(new Error(`Retry limit ${retryCount} exceeded`))
    )
  );
}

Дополнение от 18 мая 2019

На недавно прошедшей конференции ngConf Ben Lesh & Tracy Lee представили доклад на схожую тему "How To Build Your Own RxJS Operators

Затрагивается важный момент про читаемость кода.

• RxJS: Combining Operators
• RxJS 5.5, piping all the things
• rxjs observable reusing logic