У меня очень простое времяInterval наблюдаемое, и я хочу начать/остановить передачу без отключения подписчиков (которые должны сидеть и ждать независимо от наблюдаемого статуса). Возможно, и если да, то как?
var source = Rx.Observable
.interval(500)
.timeInterval()
.map(function (x) { return x.value + ':' + x.interval; })
.take(10);
var subscription = source.subscribe(
function (x) {
$("#result").append('Next: ' + x + ' ');
},
function (err) {
$("#result").append('Error: ' + err);
},
function () {
$("#result").append('Completed');
});
Общий комментарий: большинство примеров, которые я видел, показывают, как определять наблюдаемые и подписчиков. как влиять на поведение существующих объектов?