Rxjs承诺像Observable

Question

我想找一个收据提供Promise类似的Observable
意思:它Observable提供单个值并完成,
任何订阅者(完成之前和之后)应该获得该单个值.
我想出了一个组合Rx.Observable.create publishLast和connect.

var getPromiseLike=function(){
  console.log('getPromiseLike()');
  //// var an_object={}; <--- this should happen inside Obs function
  var prom_like = Rx.Observable.create(function(obs) {
    var an_object={};   /// <--- here !
    setTimeout(function(){
      obs.onNext(an_object);
      obs.onCompleted();
    },500);
  }).publishLast();
  prom_like.connect();
  return prom_like;
};

var promiselike=getPromiseLike();

var obj1;
promiselike
  .subscribe(function(obj){
    console.log('onNext1');
    obj1 = obj;
  },
  function(err){},
  function(){
    console.log('onComplete1');
  });


setTimeout(function(){
  promiselike
    .subscribe(function(obj){
      console.log('onNext2 obj1===obj :'+(obj1===obj)); //true
    },
    function(err){},
    function(){
      console.log('onComplete2');
    });
},1000);

/*LOGS:
getPromiseLike()
script.js:19 onNext1
script.js:24 onComplete1
script.js:31 onNext2 obj1===obj :true
script.js:35 onComplete2
*/

这是最简单的解决方案还是我错过了一些内置？ plnkr

Answer 1

在RxJS中,通常用类似构造的承诺建模AsyncSubject.

它有许多承诺具有并且有用的属性:

• 它只接收一个像promise一样的值,并且只会使用该值调用next.
• 它为所有未来的计算缓存了这个值.
• 它是一个主题,所以它就像是一些承诺库中的延迟.

注意:我个人认为将promises与observable混合没有问题,我在自己的代码中执行它,Rx很好地使用promises.