56. Final exam: liveSearch operator

Финальный экзамен — production-grade liveSearch

Поздравляем — это последний урок курса. Здесь мы соберём всё вместе: операторы для управления потоком, обработку ошибок, повторные попытки, fallback. Получится оператор, который реально готов работать в production.

Полная цепочка

function liveSearch(searchApi) {
  return source$ => source$.pipe(
    debounceTime(20),         // ждём паузу в наборе
    distinctUntilChanged(),   // отсекаем повторы
    switchMap(query =>
      searchApi(query).pipe(  // внутренний запрос
        retry(1),             // одна повторная попытка
        catchError(() => of('Fallback: ' + query))  // последняя линия защиты
      )
    )
  );
}

Почему именно так

• retry и catchError стоят внутри switchMap — это критически важно. Если их вынести наружу, ошибка одного запроса убьёт весь поток поиска навсегда.
• retry(1) — одна повторная попытка для случайных сбоев сети.
• catchError — последняя страховка: если retry не помог, возвращаем безопасную строку.

const { of, defer, debounceTime, distinctUntilChanged, switchMap, retry, catchError } = Rx;

function liveSearch(searchApi) {
  return source$ => source$.pipe(
    debounceTime(20),
    distinctUntilChanged(),
    switchMap(query => {
      return searchApi(query).pipe(
        retry(1),
        catchError(() => of('Fallback: ' + query))
      );
    })
  );
}