9. defer: фабрика на каждую подписку

Проблема: значение зависит от момента подписки

Представьте: вы хотите создать Observable, который вернёт текущее время. Если написать of(Date.now()), время «заморозится» в момент создания Observable. Все подписчики получат одно и то же — даже если подписались спустя час.

Решение: defer

defer(factory) принимает функцию-фабрику. Она вызывается заново каждый раз, когда кто-то подписывается. Внутри можно вычислить актуальное значение или построить новый Observable.

defer(() => of(Date.now()))
// Каждый подписчик получит свежий Date.now()

Где это полезно

• Текущая дата, актуальный токен авторизации.
• Свежий HTTP-запрос: повторная подписка должна делать новый запрос, а не возвращать кэш.
• Любое значение, которое должно вычисляться в момент подписки, а не при создании.

Глоссарий

• Фабрика (factory) — функция, которая по требованию создаёт нечто новое. В defer она создаёт Observable.

const { defer, of } = Rx;

let calls = 0;

const request$ = defer(() => {
  calls++;
  console.log('Factory call: ' + calls);
  return of('Data ' + calls);
});

console.log('Sub A');
request$.subscribe(value => console.log(value));

console.log('Sub B');
request$.subscribe(value => console.log(value));