1

假设我有一个这样的数组：

const values = [1,2,3];

我从这个数组中创建了一个 observable，如下所示：

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

这是一个小提琴：

https://jsfiddle.net/mcq40Lmg/

4

1 回答 1

1

如果您正在寻找通过直接调用推送值的功能，您将需要使用Subject<T>.

const values = Rx.Observable.Subject();

setTimeout(function(){

   values.onNext(4);
   values.onNext(5); 
   values.onNext(6);

}, 3000 );

在日常操作中使用主题不被认为是一种好的做法，并且违背了 Rx 的精神。主题本质上是 Rx 的可变变量。

您可以从内置运算符中获得您想要的任何功能，或者创建结合现有运算符的新功能。

于 2016-12-19T04:39:38.370 回答