angular - 将 Angular2 Http 响应转换为 ConnectableObservable

Question

我必须承认，我正在使用 Angular2 迈出第一步，我在这里遇到了一个问题，我对此有一些理解上的问题。我使用的是 angular2@2.0.0-beta.0，它依赖于 rxjs@5.0.0-beta.0。

我的目的是发出 HTTP 请求(向 REST 服务)并允许将响应发送到返回的可观察值的多个订阅者。如果我正确理解文档，我可以使用publish()函数来转换由例如返回的Observable将 http.post 函数发送到 ConnectableObservable，通过多次调用 ConnectableObservable.subcribe(...) 来注册多个订阅者，然后调用 ConnectableObservable.connect() 来实际执行 HTTP 请求，例如像这样:

var obs: Observable<Response> = this.http.post(...);
var cobs: ConnectableObservable<Response> = obs.publish();
cobs.subscribe(sub1);
cobs.subscribe(sub2);
cobs.connect();

至少我的 IDE 同意这一点并且没有显示任何警告。运行代码，但我收到以下错误:

EXCEPTION: Error during evaluation of "click"
ORIGINAL EXCEPTION: TypeError: obs.publish is not a function

如果我在调试器中检查 obs 对象，只会发现 documented functions 的一个非常小的子集。实际上是可用的。如果我查看 implementation of the Observable类中，只有少数记录的函数确实实现了。大多数函数，其中包括 publish 函数，仅声明为函数签名，而没有任何实际实现。

我在这里做了一些明显错误的事情，还是我完全误解了如何使用 RxJS 可观察量？

如果重要的话，我正在使用 gulp 进行构建，使用 npm 来解析和下载依赖项，并从我的 node_modules 目录中包含 rxjs/bundles/Rx.js 。

Answer 1

事实上，我认为使用 ConnectableObservable 是没有必要的。这是我所做的测试，当收到响应时，两个订阅者都会被调用:

var observable =
  this.http.get('https://angular2.apispark.net/v1/companies/')
           .map(res => res.json());

observable.subscribe(
  data => console.log('subscribe #1'));
observable.subscribe(
  data => console.log('subscribe #2'));

编辑

我认为 share 运算符可以满足您的需求:

var observable =
  this.http.get('https://angular2.apispark.net/v1/companies/')
           .map(res => res.json()).share();

observable.subscribe(
  data => console.log('subscribe #1'));
observable.subscribe(
  data => console.log('subscribe #2'));

它允许创建一个可连接的可观察对象(share 方法返回一个热可观察对象)。在这种情况下，只执行一个 HTTP 请求...

这个问题可能对您有帮助:Hot and shared Observable from an EventEmitter .

编辑1

经过评论中的一些讨论，问题似乎是关于为什么会发生以下错误:TypeError: obs.share is not a function以及为什么几乎所有记录的函数在post 函数返回的可观察值。

因此解决方案是显式导入 RxJS 运算符以使其在运行时可用。

有两种解决方案。每个运算符导入:

import 'rxjs/add/operator/map'

或者更一般地说，如果您想拥有可观察量的所有可用运算符方法:

import 'rxjs/Rx';

希望对你有帮助蒂埃里