zip 2 observable everytime one of them emit

user_3241192 0
Viewed 283

I have the following

const timer1 = interval(1000).pipe(take(10));
const timer2 = interval(2000).pipe(take(6));
const merged = merge(timer1, timer2);
merged.subscribe(x => console.log(x));

Now this will only provide the value of the latest emitting observable.

I would like that, when one emit, I get the new value, and the latest from the other one.

I tried to use zip but it will not use the latest. Check the screenshot below for the missing value I wish to have. How can I achieve this ?

Join, would work, but join do not emit if the same observable emitted twice before the other one emitted a value.

enter image description here

rxjs
1 Answers

You are looking for combineLatest.

combineLatest will emit whenever either of the source observables emit. Note: it will not emit for the first time until each observable has emitted at least once.

combineLatest marbles

So with your example, it could look like this (StackBlitz):

const timer1 = interval(1000).pipe(take(10));
const timer2 = interval(2000).pipe(take(6));
const merged = combineLatest([timer1, timer2]);

merged.subscribe(([one, two]) => console.log(`${one}-${two}`));
user_18583570
Related