rxjs5

-1热度

4回答

我有一个使用角度的HTTP服务 @Injectable() export class MyService { constructor(private http: Http) { } getThings() { return this.http.get('url').map((res) => { // massage data here and ret

1热度

2回答

如何链接RXJS中的承诺列表？

如何链接RXJS中的承诺列表？每一个承诺需要执行时，先前解决（工作todo是有状态的）。我现在做它的方式原始的感觉： const workTodo = []; // an array of work const allWork = Observable.create(observer => { const next=() => { const currentTodo = w

1热度

2回答

rxjs发出并行请求并等待两个完成并更新后，其中一个发出

我的要求是，我有两个端点一个列出HondaCars和一个列表PeugoetCars当我使用combineLatest运算符时，它不会等待另一个流完成; 这里我的要求=>第一次等待，直到两个源流两者的一个后收到的值那么刷新后接收的值编辑所以经过搜索的一段时间，我只是贴有combineLatest但诀窍是在这里： this.loading = Observable.combineLatest(

1热度

1回答

可观察的计时器永远不会完成尽管takeUntil

我有很多痛苦的理解，为什么我的观察从未完成。我的代码应该是这样的工作：初始化为false 主题isTimerEnabled$这是switchMap倒是来，要么返回Rx.Observable.never()时isTimerEnabled$发出假的，否则它映射到一个功能Rx.Observable.timer可观察从计时器我take一切为1秒。 1秒后，可观测完成的问题是，当我订阅了这一切，我的

-1热度

1回答

Rxjs调用返回页面中的数据的服务

我需要为列表[“A”，“B”，“C”]中的每个项目调用Web服务。该服务将返回页面中的数据（默认页面大小为100）。服务的第一次调用（使用page = 1作为参数）将有记录的总数设置为响应中的标题，并基于我需要多次调用该服务。我需要等待所有调用的响应，才能继续进一步的逻辑。任何指针来实现上述使用Rxjs将有很大的帮助

0热度

1回答

如何正确调用/管理我的可观察项的后续订阅？

试图创建一个可以推送给所有订阅者的可观察对象，但是我遇到了多个订阅的问题。这是我的理解，订户管理是为我自动处理的。在下面的例子中，我的目标是记录'a'和'b'。 let observer = null as any; let ob$ = new Observable<any>(ob => { //this piece of code will be called twice, over

3热度

1回答

让潜在异步RxJS观察到的肯定异步

有潜在异步观察到，即是这样的： const potentiallyButNotNecessarilyAsyncObservable = [ Observable.of('sync'), Observable.of('async').delay(100) ][Math.round(Math.random())]; potentiallyButNotNecessarilyAs

1热度

2回答

concatMap可变数量的承诺和管道结果作为下一个承诺的参数

我有一个可变数量的承诺，我想依次将前一个承诺的结果作为下一个承诺的参数执行它们。目前，我设法Concat的，以便他们按顺序执行它们： const promises = [p1, p2, p3, p4, ....]; const source$ = promises.map(p => Rx.Observable.defer(p)); const combination$ = Rx.Observa

0热度

1回答

如何更改RxJS使用的默认调度程序？

据我所知在旧RxJS 4我可以更改默认调度程序猴修补DefaultScheduler.prototype。这是正确的，或者有更好的方法来做到这一点？这是可能实现在更新的RxJS 5。因为正如我在源代码中看到的那样，它们使用null作为默认调度程序，但不能进行猴子修补。例如here 那么如何更改RxJS使用的默认调度程序？（用于测试，调试或只是为了好玩）

3热度

1回答

RxJS 5，转换可观察到一个BehaviorSubject（？）

我有可观察到的，一旦它具有订户，将做查找一个父和发射一个单一的值，则完成了。我想那转化为可观察到的（或行为主体或任何作品），其执行以下操作：一旦它至少有一个用户，它会从父观察到的（一次）的结果。然后它将这个价值发放给它的所有用户，并且当它们订阅时也将这个单一价值发给所有未来的订户。即使用户数减少到零，它也应该继续这种行为。看起来这应该很容易。这里是没有工作： theValue$: Observ