Блог

Я читаю документы для mapTo и я просто не понимаю смысла существования этого оператора. Я понимаю, что он делает, но две строки ниже должны привести к эквивалентному результату.

 const outcome = "bzzz";
const result1 = source.map(a => outcome);
const result2 = source.mapTo(outcome);
 

Тем не менее, создатели RxJS решили увеличить сложность, добавив дополнительный метод. Это кажется бессмысленным как таковое, поэтому я подозреваю, что в этом есть нечто большее, чем кажется на первый взгляд.

Какой смысл иметь выделенный оператор для такого конкретного случая?

Различия между map и mapTo

• map исходный код
• mapTo исходный код

На первый взгляд, мы видим, что map он принимает функцию обратного вызова

 function map<T, R>(project: (value: T, index: number) => R, thisArg?: any)
 

принимая mapTo во внимание, что принимает статическое значение

 function mapTo<R>(value: R)
 

Итак, явное различие заключается в том, что map функция обратного вызова может генерировать значение в зависимости от предоставленных аргументов. Это не тот случай mapTo , когда вы просто предоставляете значение, которое всегда будет передаваться следующему подписчику в цепочке. Если хотите, mapTo(value) можно использовать как

 map(() => value)
 

Мы также можем вывести это из исходного кода:

 // `mapTo`
() => subscriber.next(value)

// `map`; `project` is the provided callback function
() => subscriber.next(project.call(thisArg, value, index  ));
 

Но вы можете не захотеть этого делать, зачем вызывать функцию, когда вы можете напрямую использовать значение?

Некоторые варианты использования

Примером использования может быть, когда у вас есть эффект NgRx, и вы хотите вернуть то же самое, нединамическое действие, когда что-то происходит.

 createEffect(
  () => this.actions.pipe(
    /* some logic here... */
    mapTo(staticAction('a message here')),
  )
);
 

Еще один, который может показаться не очень практичным, — это когда вы хотите имитировать некоторые поступающие запросы:

 merge(
  timer(300).pipe(mapTo("req#1")),
  timer(600).pipe(mapTo("req#2")),
  timer(100).pipe(mapTo("req#3")),
  timer(900).pipe(mapTo("req#4")),
).pipe(
  /* some complicated logic here... */
)
 

В любом случае, смысл этого оператора, по крайней мере, с моей точки зрения, в том, чтобы указать, что вы хотите передавать статические значения, то есть значения, которые не зависят от данных предыдущего подписчика.

mapTo на самом деле это просто удобство для конкретного сценария сопоставления, где:

1. Вывод не зависит от эмиссии из наблюдаемого источника
2. Вывод всегда будет одним и тем же статическим значением

Важно отметить второй момент, потому что, если целевое значение изменяется со временем, в выходных данных будут различия между map(a => target) и mapTo(target) :

• map(a => outcome) — вернет текущее значение «результат» (возможно, разные результаты)
• mapTo(outcome) — вернет первое переданное значение «результат» (один и тот же результат каждый раз)

 let outcome = 0;
// change 'outcome' every second
interval(1000).pipe(tap(n => outcome = n * 2)).subscribe();

const source = interval(1000).pipe(take(4));

source.pipe(map(a => outcome));  // 0, 2, 4, 6
source.pipe(mapTo(outcome));     // 0, 0, 0, 0
 

Демонстрация StackBlitz