像 Observable 一样的 Rxjs Promise

Question

我想找一张收据，以提供Promiselike Observable
我的意思是： Observable 提供单个值并完成，
并且任何订阅者（完成之前和之后）都应该获得该单一值。
我提出了Rx.Observable.createpublishLast 和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 中，类似 promise 的构造通常使用 AsyncSubject 建模。

它具有许多 Promise 所具有且有用的属性：

• 它只接收一个值，如 Promise，并且只会使用该值调用 next。
• 它会缓存该值以供将来所有计算使用。
• 它是一个 Subject，所以它在某些 Promise 库中类似于一个延迟。

---

注意：我个人认为将 Promise 与 observables 混合没有问题，我在自己的代码中这样做，并且 Rx 很好地使用了 Promise。