Angular - 终止 Observables 的首选方法是什么？
在我对Angular和RxJs的理解中，有两种方式可以终止Observables。你可以使用unsubscribe()来取消订阅，或者使用takeUntil()和complete()。以下是每种方法的示例（伪代码）。 使用unsubscribe()方法 private _id: numbe...
有条件的Observable.forkJoin()构建
根据函数参数，我想构建forkJoin()方法。 例如： 如果parameter1为空 => 不要在forkJoin()中放入http请求 如果parameter2为空 => 不要在forkJoin()中放入http请求 代码: getAllByIds(paramete...
如何从函数创建可观察对象？
我想同步调用一个函数，并使用其返回值作为初始发射值（随后在生成的Observable上链接其他操作符）。 我想在订阅期间调用此函数，因此无法仅使用Observable.of(() => getSomeValue())。我见过bindCallback（以前是fromCallback），但我...
如何将自己的 RxJS 主题双向绑定到 [(ngModel)]？
有没有一种简短而简单的方法将 RxJS Subject 或 BehaviorSubject 传递给 Angular 2 指令以进行双向绑定？较长的方法如下：@Component({ template: ` <input type="text" [ngModel]=...
使用RxJS进行Angular 2轮询
我正在尝试轮询一个RESTful端点以刷新我的实时聊天消息。我知道实时聊天的最佳方法是Websockets，我只是想了解RxJS如何与Angular 2配合使用。我想每秒检查一次新消息。我有以下代码：return Rx.Observable .interval(1000) .fla...
如何模拟 RXJS 5.5.6 中的 fromEvent 函数？
我需要测试一个使用了fromEvent可观察函数的功能。在升级到“可订阅”运算符之前，我只是这样做： spyOn(Observable, 'fromEvent').and.callFake(mockFromEventFunction) 但是现在，Rxjs已经改变了，Observable....
RXJS 5中的.subscribe()方法不带参数
一个快速的问题。我已经使用RxJS 5几个月了，遇到了一些行为，我真的不理解，因为我无法在任何地方查找它。 我的情况是，仅使用.subscribe();订阅一个可观察链并不会触发observable。 但是，如果我添加一个onNext回调（空或非空），则observable会被触发，并且链会处...
如何在Angular2中停止observable.timer
我正在Angular2的组件中实现以下功能: export class MypageEditComponent { ngOnInit() { this.timer = Observable.timer(100, 100); this.timer.subscribe(t ...
如何强制让Observables按顺序执行？
我正在从 Promise 的世界转向 Observable 的世界。我通常会使用 Promise 链接一系列任务并使它们按顺序运行。例如，我有三个任务：printLog1() 用于将“1”打印到控制台，printLog23() 用于将“2”和“3”打印到控制台，以及 printLog4() 用...
Angular2：如何正确地在服务和组件中订阅Http.post可观察对象？
对于JWT认证，我使用新的Http模块与Observables一起工作来进行post请求以获取令牌。 我有一个简单的Login组件，显示表单： @Component({ selector: 'my-login', template: `<form (submit)="subm...