народ вопрос из области rxjs чет голову сломал.
как мне буферизовать то что эмитится в сабжекты и считалось до того как я сделал первую подписку?
const subj1 = new Subject<number>();
const subj2 = new Subject<number>();
const subj3 = new Subject<number>();
const merged = merge(subj1, subj2, subj3).pipe(
startWith(0),
pairwise(),
map(value => value[0] + value[1]),
shareReplay(1)
);
subj2.next(2);
merged.subscribe(v => console.log(v));
subj1.next(1);
merged.subscribe(v => console.log(v));
subj1.next(1);