Подписки на события используя RxJs

Если добавить лог в callback:

let source = Observable.create(obs => {
    console.log('callback');
    observer = obs;
});

можно заметить, что он будет вызываться при каждом вызове subscribe.

Соответственно, при каждом вызове будет переписана глобальная переменная, в которой сохранится последнее значение.

Для решения можно воспользоваться методом share

let source = Rx.Observable.create(obs => observer = obs).share();

В этом случае один наблюдатель будет для всех подписок.

Пример

Альтернативным решением может стать использование Subject вместо Observable.create

let source = new Subject();
source.subscribe(m => console.log(`subscribe 1: ${m}`));
source.subscribe(m => console.log(`subscribe 2: ${m}`));
source.next("hello!:)");

Пример