RxJS, оператор для применения функции к наблюдаемой в зависимости от ее положения

Question

Допустим, у меня есть наблюдаемые X, Y и Z. Есть ли оператор RxJS, который применяет действия в зависимости от позиции каждого действия, например:

concat(x, y, z).pipe(someOperator(a, b, c)).subscribe(done);

, поэтому выбрасывается значение X будет обработано A, значение Y будет обработано B и т. д.

Answer 1

Вы можете просто сделать это, как показано ниже, но чтобы сделать это красиво, вы можете создать своего собственного оператора, если это частая операция

from([{obs:z, fn:a},{obs:y, fn:b},{obs:z, fn:c}]).pipe(
mergeMap(({obs,fn})=>obs.pipe(map(value=>fn(value))
).subscribe();