class MySubject extends Rx.Observable { constructor() { super(); } next() {} error() {} complete() {} }