rxjs5

3热度

1回答

当我一直在寻找通过我碰到这个功能跌跌撞撞rxjs库： export function map<T, R>(this: Observable<T>, project: (value: T, index: number) => R, thisArg?: any): Observable<R> { if (typeof project !== 'function') { throw

2热度

1回答

在处理多个项目后在RxJS中运行单个操作

我对RxJs比较新，在处理使用switchMap运算符发出的多个项目后无法链接单个操作。场景：使用后端数据为下拉列表生成对象数组，然后链接单个操作以设置下拉列表的选定值。下面是有助于说明问题的非工作代码。 this.sub = this.dataService.getUserData() .switchMap((data) => Observable.from(data)) // c

1热度

1回答

如何使用.distinct通过一个对象属性的内容从一个数组中删除对象

我想了解我的用例的.distinct操作：通过用户输入我做的是一个国家的搜索并且只想在名为country的属性中仅显示具有特定内容的一个对象。说明：我有各种物体的内容的BehaviorSubject： [ {id:1, country: "United Kingdom", city:"London"}, {id:2, country: "United Kingdom", city:"Ma

0热度

1回答

错误的角度和RXJS承诺

我期待从2角一个应用程序升级到4，我发现了以下错误： Type 'Promise<void | Store>' is not assignable to type 'Promise<Store>'. 类型“无效|商店'不能分配键入'存储'。类型'void'不可指定为'Store'类型。有问题的线路是这样的： return this.http.get(url, { headers: this

1热度

3回答

rxjs5合并和错误处理

我想合并/合并多个观察对象当他们每个完成时执行一个最后函数。 merge运营商似乎并行执行每个订阅，这是我需要的，但如果他们中的任何一个抛出一个错误执行被暂停。 RxJS 4版有一个运营商mergeDelayError应该继续执行，直到所有的人都完成了所有订阅，但该运营商不版本5实现。我应该回到不同的操作员吗？ var source1 = Rx.Observable.of(1,2,3).dela

1热度

2回答

使用forkJoin的打字稿打字错误

使用forkJoin操作员窗体RxJS时，遇到TypeScript类型检查失败。这是有问题的代码： let products = this.http.get(productUrl, { headers: this.headers }) .map(response => response.json().data as Product[]); let loans = Obs

4热度

2回答

RxJS combineLatest operator怪异行为

我有一个关于RxJS combineLatest操作符的查询。我已经修改了在 https://www.learnrxjs.io/operators/combination/combinelatest.html 给出的示例如下： //timerOne emits first value at 1s, then once every 4s const timerOne = Rx.Observable

1热度

1回答

observable forkjoin永远不会执行可观察的angular2

我试图使用forkJoin执行多个XHR请求（在getImages函数中），每个请求都包含在可观察对象（在getImage函数内）中。然而，没有任何请求被执行，即从不执行observer.next()。我曾尝试使用zip而不是forkJoin，但这也不起作用。我确信我可以在我创建的所有观察对象上都有complete。 getImages(urls: string[]) { Observa

0热度

1回答

如何在RxJs 5中将项目分组为大小为n的组？

我需要帮助将无限数据流上的项目分组而不会丢失数据。组的大小必须不大于n个元素。如果在一段时间内没有物品出现，那么当前组的大小可能小于n。试图验证码： Observable.create(observer => { setTimeout(() => observer.next([1]), 90) setTimeout(() => observer.next([2, 3])

1热度

1回答

返回从rxjs/Subject（Observable.from vs Observable.of）数组的观测值

我正在使用WebSockets与后端WebApi进行通信。一切工作正常，除了我不能从我的服务返回我的自定义对象。我正在使用Angular 4.3.4和rxjs 5.4.3。 //ngInit from my component ngOnInit() { this.modelsSubscription = this.mainService.getModels().subscribe(m