小编Mar*_*y B的帖子

我想监视何时使用observable将对象推送到数组上.我想从一个空数组开始,当发生推送时,我希望observable检测并处理它,然后等到下一次推送.这与"fromEvent"非常相似,其中observable等待事件.下面的代码立即调用completed(),因为数组是空的,我如何让它等待推送？

    var testArray = [];

    test(){
      var o = {timestamp: new Date()}
      testArray.push(o)
    }

    var o = Observable
        .from(testArray)
        .concatMap( x => {
          return x;
    });

    o.subscribe( 
      x => { console.log("onNext x=",x.timestamp) },
      e => console.log('onError:', e),
      () => {console.log('onCompleted');} );

注意:输入机制不必是数组.任何类型的消息队列对象都适用于我.