Публикация

Указанные выше операторы доступны в следующих пакетах:

• rx.all.js
• rx.all.compat.js
• rx.binding.js (требует либо rx.js, либо rx.compat.js)
• rx.lite.js
• rx.lite.compat.js

RxJS также имеет оператор multicast, который работает с обычным Observable, мультиплицирует это Observable с помощью указанного вами Subject, применяет трансформирующую функцию к каждому излучению и затем излучает эти преобразованные значения как собственную обычную последовательность Observable. Каждая подписка на это новое Observable будет запускать новую подписку на основное мультиплицируемое Observable.

Пример кода

var subject = new Rx.Subject();
var source = Rx.Observable.range(0, 3)
    .multicast(subject);

var observer = Rx.Observer.create(
    function (x) { console.log('Next: ' + x); },
    function (err) { console.log('Error: ' + err); },
    function () { console.log('Completed'); }
);

var subscription = source.subscribe(observer);
subject.subscribe(observer);

var connected = source.connect();

subscription.dispose();

Next: 0
Next: 0
Next: 1
Next: 1
Next: 2
Next: 2
Completed

Оператор multicast доступен в следующих пакетах:

• rx.all.js
• rx.all.compat.js
• rx.binding.js (требует либо rx.lite.js, либо rx.compat.js)
• rx.lite.js
• rx.lite.compat.js

Также существует оператор let (псевдоним letBind доступен для браузеров, таких как Internet Explorer до IE9, где «let» запрещен). Он похож на multicast, но не мультиплицирует основное Observable через Subject:

Пример кода

var obs = Rx.Observable.range(1, 3);

var source = obs.let(function (o) { return o.concat(o); });

var subscription = source.subscribe(
    function (x) { console.log('Next: ' + x); },
    function (err) { console.log('Error: ' + err); },
    function () { console.log('Completed'); });

var subscription = source.subscribe(
    function (x) { console.log('Next: ' + x); },
    function (err) { console.log('Error: ' + err); },
    function () { console.log('Completed'); });

Next: 1
Next: 2
Next: 3
Next: 1
Next: 2
Next: 3
Completed

Оператор let (или letBind) доступен в следующих пакетах:

• rx.all.js
• rx.all.compat.js
• rx.experimental.js

Он требует одного из следующих пакетов:

• rx.js
• rx.compat.js
• rx.lite.js
• rx.lite.compat.js