Kata

Create a basic Merge operator from RxJS library using JavaScript. This operator will combine multiple Observables into a single Observable, emitting values from all source Observables concurrently.

Requirements

1. Implement the merge operator to combine multiple source Observables into a single Observable.
2. Ensure that the operator follows RxJS conventions and integrates seamlessly with existing Observables.

Note

The Observable-like class has already been implemented inside the kata. So you are able to use new Observable, pipe, of, interval

Usage example

const source1$ = Observable.of(1, 2, 3);
const source2$ = Observable.of(4, 5, 6);
// Also possible: 
// const source2$ = new Observable(observer => { observer.next(1) });
const merged$ = merge(source1$, source2$);

merged$.subscribe({
  next: value => console.log(value),
  error: err => console.error('Error:', err),
  complete: () => console.log('Completed')
});
// Output: 1 2 3 4 5 6 Completed

Have fun!😀