假设我有一个像这样的数组：
const values = [1,2,3];
我从该数组创建一个可观察对象，如下所示：
const obs = Rx.Observable.from(values);
我这样订阅：
obs.subscribe(
function onNext(result){
console.log('item =>', result);
},
function onError(e){
console.error(e.stack || e);
},
function onCompleted(){
console.log('observable is completed');
}
);
我遇到的问题是，如果我像这样将新项目推送到数组中：
setTimeout(function(){
values.push(4);
values.push(5);
values.push(6);
}, 3000 );
这些项目（4,5,6）不会显示在subscribe（）回调中！
所以我的问题是，我们如何创建一个可观察的数组，该数组可以“保持打开状态”，以便将来将项目推入该数组时，将触发观察者回调？
我为此创建了要点：
https://gist.github.com/ORESoftware/677ad0a3adf41c04a60829921ba4c4c4
这是一个小提琴：
如果您正在寻找通过直接调用推送值的功能，则需要使用Subject<T>。
const values = Rx.Observable.Subject();
setTimeout(function(){
values.onNext(4);
values.onNext(5);
values.onNext(6);
}, 3000 );
使用主题进行常规操作不被认为是一种好习惯，并且违反了Rx的精神。本质上，主题是Rx的可变变量。
您几乎可以从内置运算符中获得所需的任何功能，或创建将现有功能组合在一起的新功能。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句