25. switchMap: последний запрос побеждает

switchMap — последний побеждает

switchMap ведёт себя иначе: при появлении нового внешнего значения он отменяет текущий внутренний Observable (если тот ещё работает) и запускает новый.

входы:  'a' → 'an' → 'angular'
switchMap: запрос(a) → отмена → запрос(an) → отмена → запрос(angular) → результат

Главный сценарий — typeahead

Пользователь печатает в поиске. Каждый промежуточный запрос (для «a», «an») уже не нужен — нужен только последний. switchMap бесплатно даёт «отмену устаревших запросов», что особенно ценно для HTTP в Angular.

Сводка четырёх операторов

• mergeMap — параллельно, порядок не важен.
• concatMap — очередь, строгий порядок.
• switchMap — отменяем старое, оставляем новое.
• exhaustMap (следующий урок) — игнорируем новое, пока старое работает.

const { timer, switchMap, map } = Rx;

const source$ = hot('a 19ms b 19ms c|', {
  a: 0,
  b: 1,
  c: 2,
});

const result$ = source$.pipe(
  switchMap(value => {
    return timer(50).pipe(
      map(() => 'Done ' + value)
    );
  })
);