热和冷的可观察对象：是否存在“热”和“冷”运算符？
我查看了以下SO的问题：What are the Hot and Cold observables? 总结如下： 冷observable会在有观察者来消费它们时发出其值，即观察者接收到的值序列与订阅时间无关。所有观察者将消费相同的值序列。 热observable独立于其订阅而发出值，即观...
使用rxjs5获取BehaviorSubject的当前值的简单方法
RxJS4 中，BehaviorSubject 有一个叫做 getValue() 的方法 (文档在这里)。 RxJS5 中已经没有了这个方法。 因此，我找到的唯一解决方案是：let value; myBehaviorSubject.take(1).subscribe( (e) => va...
尝试防止重复订阅时出现ObjectUnsubscribedError错误
我有一个服务和一个使用它的组件： PagesService PagesListComponent 在PagesService中，我有一个Pages数组。通过BehaviorSubject通知数组中的更改，两者都订阅了这个通知。 PagesService提供在bootstrap中，以便...
在RxJS Observable中“扁平化”数组的最佳方法
我的后端经常将数据作为一个包含在 RxJS 5 Observable 中的数组返回（我在使用 Angular 2）。 我经常希望能够使用 RxJS 操作符 单独处理数组项，我使用以下代码实现（JSBin）：const dataFromBackend = Rx.Observable.of([ ...
如何定时发送HTTP请求？
我对angular和rxjs比较陌生。 我试图创建一个angular2应用程序，从静态文本文件（在本地服务器上）获取一些数据，并希望使用Angular2的http提供程序和rxjs的map在固定时间interval(5000)将其检索并映射到Datamodel。以反映所提供的txt文件的任何更...
Angular2：在服务中取消订阅HTTP可观察对象
在Angular2服务中取消订阅http订阅的最佳实践是什么？ 目前我这样做，但不确定这是否是最佳方式。import { Injectable } from "@angular/core"; import { Http } from "@angular/http"; import { Su...
RxJs 5 的 share() 操作符如何工作？
对我来说RxJs 5的share()操作符如何工作并不完全清楚，可以在此处查看最新文档。关于此问题的Jsbin请参见此处。 如果我创建了一个observable，其中包含0到2一系列的值，每个值之间相隔一秒：var source = Rx.Observable.interval(1000) ...
“Observable<T>”不是从“Observable<T>”派生的类。
当试图从node_modules中的类扩展一个类时，typescript编译器会抛出一个错误，显示： 属性“source”受保护，但类型“Observable<T>”不是派生自“Observable<T>”的类。 只有当基类来自node_module时才会发生这种情...
如何将自己的 RxJS 主题双向绑定到 [(ngModel)]？
有没有一种简短而简单的方法将 RxJS Subject 或 BehaviorSubject 传递给 Angular 2 指令以进行双向绑定？较长的方法如下：@Component({ template: ` <input type="text" [ngModel]=...
Observables (Rx.js)与ES2015生成器相比有何区别？
据我了解，以下是解决异步编程工作流的技术： 1. 回调函数 (CSP) 2. Promises 新一代方法： 1. Rx.js Observables (或 mostjs、bacon.js、xstream 等) 2. ES6 生成器 3. Async/Await 我们现在正在从回调和 ...