Distribute stream on an other stream

rx-distib.js

console.clear();

const items$ = Rx.Observable
  .interval(100)
  .map(x => `item-${x}`)
  .take(100)
  .share();

const cc$ = Rx.Observable
  .interval(0)
  .take(2)
  .scan(count => count + 1, 0)
  .share();

const zip$ = Rx.Observable
  .zip(
    items$, 
    items$.scan(count => count + 1, 0)
  );

Rx.Observable
  .combineLatest(zip$, cc$, (z, cc) => {
    return [z[0], z[1], cc];
  })
  //.subscribe(x => console.log(x));
  .groupBy(
    ([i, c, cc]) => c % cc,
    ([i, c, cc]) => ([i, c, c % cc])
  )
  .flatMap(x => x)
  .subscribe(x => console.log(x));