RxJs从产生的promise中创建可观察的

Question

我对RxJs还比较陌生，我想了解与Rx结合使用Promises的最佳方式是什么。

我想要创建的是Angular中的一个服务，它的作用类似于事件分派器模式，一旦promise完成，就会发出一个事件。我还需要的是，如果没有（事件）订阅者，则永远不会调用可观察对象。我最不希望发生的事情是，observable的任何后续订户都会得到相同的结果，而不会触发对服务器的另一个请求。我在这里实现了自己的解决方案：

// ... CountryService code

var COUNTRIES_LOADED = Rx.Observable
    .create(function (observer) {
        $http
            .get('/countries')
            .then(function (res) {
                observer.onNext(res);
            }, function (err) {
                observer.onError(err);
            })
            .finally(function () {
                observer.onCompleted();
            });
    })
    .shareReplay();

现在，每当我订阅一个新的“监听器”主题时，可观察的对象就会被拉出来。任何新订阅者都将获得缓存的值，而无需再次接触服务器。

所以在我的“消费者”（角度指令）中，我想做如下事情：

// ... countryInput directive code:

COUNTRIES_LOADED.subscribe(function (response) {
    // Fill in countries into scope or ctrl
    scope.countries = response.countries;
});

任何未来的国家/地区/地区/地区/地区/地区/地区/地区/地区/地区/地区的订阅方不得触发$http请求。同样，如果该指令从未包含在页面中，则永远不会调用$http。

上面的解决方案是有效的，但是我不知道这种方法的潜在缺点和内存影响。这是一个有效的解决方案吗？使用RxJs是否有更好/更合适的方法来实现这一点？

非常感谢！

Answer 1

我在这里找到了答案（只是名称略有不同）rxjs在订阅时只使用一次promise

所以对于我的例子，答案很简单：

var loadCountries = function () { return $http.get('/countries'); };

var observable = Rx.Observable.defer(loadCountries).shareReplay();

Answer 2

使现代化

从rxjs6开始，您可以使用from（）

您是否尝试使用rxjs5的fromPromise（）API？

检查这里的文档！

Answer 3

使用Rx。可见的。fromPromise（promise）

来自promise：

将Promises/符合规范的Promise和/或符合ES2015的Promise转换为工厂函数，该函数将该Promise返回到可观察序列。

例子：

var source = Rx.Observable.fromPromise(promise);

var subscription = source.subscribe(
  function (x) {
    console.log('Next: %s', x);
  },
  function (err) {
    console.log('Error: %s', err);
  },
  function () {
    console.log('Completed');
  });

使现代化

rxjs6方法是来自