rxjs相关内容

升级到 RC 6 和 RxJS Beta 11 后缺少 flatMap

升级到 RC6 和 rxjs@5.0.0-beta.11 后,我似乎缺少一些 Observable 对象的扩展. flatMap 算子没了,mergeMap 也没有了.我现在只看到几个操作员.知道我错过了什么吗? 解决方案 我想现在您需要单独导入运算符.如果你往里面看 node_modules/rxjs/add/operator/mergeMap 你应该看到 mergeMap.d ..
发布时间:2022-01-01 22:45:31 其他开发

Angular 6 - Rxjs 6 - 类型 Observable不可分配到类型 Observable
将我的 Angular 项目从版本 5 更新到 6 后,出现此错误: 类型 Observable' 不可分配给类型 Observable'. 在我的 todo.service.ts import { Injectable } from '@angular/core';从'@angular/common/http' 导入 { HttpClient };从'../../../enviro ..
发布时间:2022-01-01 22:45:23 其他开发

RxJs:一个接一个地执行 3 个 observable,并在第二个请求中使用第一个结果,在第三个请求中使用第一个和第二个结果

我需要能够一个接一个地执行 3 个 observable,以便我可以在第二个中使用第一个的结果值,在第三个中使用第一个和第二个结果. 这样的事情(它不起作用,因为 serviceId 在第三个请求中不可见): private setupStuff(): void {this.initRouteParams().pipe(switchMap(serviceId => this.getFile ..
发布时间:2022-01-01 22:44:50 前端开发

RxJS 中的 map 与 switchMap

我阅读了 switchMap 和 map,但我仍然不完全理解其中的区别.是否在某些情况下它根本没有区别? 解决方案 两种操作符不同. switchMap:将值映射到 observable.取消之前的内部 observable. 例如: fromEvent(document, 'click').管道(//每次点击重启计数器//第一次点击:0, 1, 2...//第二次点击:取消 ..
发布时间:2022-01-01 22:44:31 其他开发

从使用 switch 构建的 observables 接收完成的通知

在下面的示例中,foo 从 bar 接收数据,但在 bar 完成时忽略.foo 在 baz 完成时完成,这不是我想要的行为. var baz = Rx.Observable.interval( 50 ).take( 10 );var foo = baz.select(函数(x){var bar = Rx.Observable.range(x, 3);返回栏;}).转变(); 是否有 switc ..
发布时间:2022-01-01 22:44:13 其他开发

为什么我的 RxJS 倒计时时钟没有显示?

我正在开发一个 Angular 9 测验应用程序,我使用 RxJS 作为倒数计时器(在容器\记分板\时间\time.component.ts 中),但计时器似乎没有显示.stopTimer() 函数应该在计时器停止的秒数上停止计时器.选择正确答案后计时器应停止,并且计时器应在问题之间重置.每个问题所用的时间应保存到 elapsedTimes 数组中.请在 Stackblitz 上的 TimeCom ..
发布时间:2022-01-01 22:44:03 其他开发

如何延迟分叉加入

你如何在 rxjs 中延迟 .forkJoin()? 这是我有但想使用 delay() 操作符? 返回 forkJoin(this.call1(),this.call2(),this.call3()); 到目前为止我得到了这个: return of(null).pipe(延迟(5000),switchmap(() => this.call1()),switchmap(() => thi ..
发布时间:2022-01-01 22:43:49 其他开发

有没有办法创建这个流序列?

我正在尝试实现这个大理石图,具有 N 个 sN$ 的 hipotesis,并且我正在将此流添加到 main$. s1$ +--1--------------------99------>s2$ +------3--------7------------------------------>main$ +---[1]-[1, 3]---[1, 7]---[99, 7]--------------> ..
发布时间:2022-01-01 22:43:42 前端开发

具有相同请求的多个 API 调用

我想使用传递不同 ID 的相同端点进行多个 HTTP 调用.有没有更好的方法来从 UI 处理这个问题.我们现在无法更改后端,有更好的方法吗? import { Component } from '@angular/core';从'@angular/common/http' 导入 { HttpClient };import { Observable, forkJoin } from 'rxjs'; ..
发布时间:2022-01-01 22:43:36 前端开发

将 Angular2 Http 响应转换为 ConnectableObservable

我必须承认我正在用 Angular2 做我的第一步,我在这里遇到了一个问题,我在理解上有一些问题.我正在使用 angular2@2.0.0-beta.0,它依赖于 rxjs@5.0.0-beta.0. 我的目的是发出 HTTP 请求(到 REST 服务)并允许将响应发送给返回的 observable 的多个订阅者.如果我正确理解文档,我可以使用 publish() 函数来转换由例如返回的 O ..
发布时间:2022-01-01 22:43:12 其他开发

Angular2:动态同步 http 请求

目标:发出一系列同步 http 请求,并能够将它们作为一个可观察流订阅. 示例(不起作用): let query_arr = ['test1','test2','test3']函数 make_request(query_arr){如果(query_arr.length){让有效载荷 = JSON.stringify(query_arr[0]);让标题=新标题();query_arr.spl ..
发布时间:2022-01-01 22:43:03 前端开发

内部有较长任务的角间隔管

我的组件中有此代码: ngOnInit() {...this.counterValue$ = 间隔(1000).pipe(switchMap(() => this.perfService.getCounter(this.counterUrl)),map(i => this.updateChart(i)),);this.counterValue$.subscribe(v => console.l ..
发布时间:2022-01-01 22:42:50 其他开发

Heroes 教程中的 Angular RXJS CatchError

我正在运行 Angular 教程,但我无法理解某一部分实际发生了什么.我从搜索中找到了一些示例,但没有具体回答这个问题.代码如下: getHeroes(): Observable{返回 this.http.get(this.heroesUrl).管道(catchError(this.handleError('getHeroes', [])));} 接下来是它调用的错误处理程序: /*** 处 ..
发布时间:2022-01-01 22:42:35 其他开发