const source = Rx.Observable.interval(1000);

const subject = new Rx.Subject();

​

const example = subject.map(x => {

  if (x === 1) {

    throw new Error('oops');

  }

  return x;

});

subject.subscribe(

    x => console.log('A', x),

    error => console.log('A Error:' + error));

example.subscribe(x => console.log('B', x),

    error => console.log('B Error:' + error));

subject.subscribe(x => console.log('C', x),

    error => console.log('C Error:' + error));

​

source.subscribe(subject);