var parent = Rx.Observable.from([1,2,3]).publish();

      var child = parent.map(x => x).publish();

​

      var groupedParent = parent.groupBy(x => x);

      var groupedChild = child.groupBy(x => x);

​

      Rx.Observable.zip([groupedParent, groupedChild])

        .subscribe(groups => {

          groups[0].subscribe(x => console.log('zipped parent ' + x));

          groups[1].subscribe(x => console.log('zipped child ' + x));

        });

​

​

      groupedChild.subscribe(group => {

        group.subscribe(value => console.log('child ' + value));

      });

​

      groupedParent.subscribe(group => {

        group.subscribe(value => console.log('parent ' + value));

      });

​

      child.connect();

      parent.connect();

​