在RxJS 5.0中找不到`combineLatest`。
以下代码在使用 RxJS 5.0 时导致了 Observable.combineLatest is not a function 的问题：let Observable = require('rxjs/Observable.js').Observable; import 'rxjs/add/op...
为什么我要使用RxJS的interval()或timer()轮询而不是window.setInterval()？
使用场景：每分钟（60000毫秒）调用一个函数，该函数分派存储操作以获取项目的lastUpdated状态，响应和过滤后更新存储库，更新后的存储库作为可观察项读取并在视图中显示。需要在 Web 应用程序开放期间一直执行此操作（因此无限期执行）。 目前，我正在使用以下内容： this.refr...
Observable.forkJoin()无法执行
我有以下代码：//Loop: For each user ID/Role ID, get the data userMeta.forEach((businessRole) => { Observable.forkJoin( af.database.object('/roles...
如何在Angular2中停止observable.timer
我正在Angular2的组件中实现以下功能: export class MypageEditComponent { ngOnInit() { this.timer = Observable.timer(100, 100); this.timer.subscribe(t ...
Angular 2 路由器使用 Observable 进行解析
在发布 Angular 2 RC.5 后，引入了路由器解析。 这里演示了一个使用 Promise 的示例，如果我使用 Observable 向服务器发出请求，应该如何做到相同的效果？ search.service.tssearchFields(id: number) { return th...
找不到模块'rxjs/subject/BehaviorSubject'。
我正在使用Angular 2。当我使用以下两种之一时，我的程序运行良好：import { BehaviorSubject } from 'rxjs/Rx'; import { BehaviorSubject } from 'rxjs'; 然而，我尝试使用以下方式：import { Behavi...
如何派发一个空动作？
我正在使用ngrx/effects。 如何分发一个空的 action？ 这是我现在的做法： @Effect() foo$ = this.actions$ .ofType(Actions.FOO) .withLatestFrom(this.store, (action, st...
如何将Observable转换为ReplaySubject？
这是我现在正在做的，将一个Observable转换为一个ReplaySubject： const subject = new Rx.ReplaySubject(1); observable.subscribe(e => subject.next(e)); 这是进行转换的最佳方式，还是...
RxJS中的first()是否需要调用unsubscribe()?
在下面的代码中：- RxJS.Observable.of(1,2).first().subscribe((x) => console.log(x);); 使用操作符first()时需要取消订阅吗？
如何一次性订阅事件发射器？
// Part of service public someEvent: EventEmitter<number> = new EventEmitter(); .... // Component @Component({ selector: 'some-component'...