如何正确链接 rxjs 6 observables?
任何建议，如何以更承诺链的风格重写?: this.apiService.sendPutRequest('/api/users/activate', usrObj).pipe(地图(() => {return this.apiService.sendGetRequest('/api/users/' + this.currentUserId).pipe(地图(数据=> {返回 this.setAct
..
rxjs相关内容
为什么你会在 Observable 函数上调用 .call() ?
我是 Angular 的相对初学者，我正在努力理解我从 ng-bootstrap 项目中阅读的一些源代码.可以在这里找到源代码. 我对 ngOnInit 中的代码很困惑: ngOnInit(): void {const inputValues$ = _do.call(this._valueChanges, value => {this._userInput = 值；如果(this.edit
..
Angular rxjs Observable.timer 不是带导入的函数
在我的角度应用程序中，我收到以下错误: 错误类型错误:rxjs_Observable__WEBPACK_IMPORTED_MODULE_4__.Observable.timer 不是功能在 SwitchMapSubscriber.project (hybrid.effect.ts:20)在 SwitchMapSubscriber.push../node_modules/rxjs/_esm5/
..
将 API 函数包装在 RxJs Observable 中
我是 RxJs 的新手，我有一个用于地理编码的 API，它提供了如下功能: simpleGeocode(options)* where options = { address: {addr: ... }, 成功:Function，失败:Function}.成功函数返回地理编码的 LatLon 对象. 我在带有 NGRX 效果的 Angular 应用程序中使用它，所以我希望将它作为 Observ
..
RXJS - BehaviorSubject:正确使用 .value
我想知道 behaviorSubject.value 是否真的有正确的用法.根据这个答案，我们应该只通过订阅获取价值. 在我看来没问题的一种情况是，我使用 .value 来确定下一个要推送到流的值，就像我切换一个简单的布尔值一样: myBoolSubject = new BehaviorSubject(false);切换(){this.myBoolSubject.next(!this.my
..
TypeScript 模块增强
我有可观察的扩展.它工作得很好，但现在我已经用 typescript 2.7.2 更新到了 angular 6. import { Observable } from 'rxjs/Observable';从 './base-component' 导入 { BaseComponent };从“rxjs/订阅"导入{订阅}；从'rxjs'导入{订阅}；声明模块'rxjs/Observable'{导出
..
如何将两个可观察数组合并为一个数组?
示例: var s1 = Observable.of([1, 2, 3]);var s2 = Observable.of([4, 5, 6]);s1.merge(s2).subscribe(val => {控制台日志(val)；}) 我想得到[1,2,3,4,5,6] 代替 [1,2,3] [4,5,6] 解决方案 forkJoin 效果很好，你只需要扁平化数组:
..
Angular6 属性“debounceTime"在“Observable<any>"类型上不存在?
按照Angular 更新指南将我的 Angular 5 项目更新为 Angular 6 后，我得到了. 属性 'debounceTime' 不存在于类型 'Observable' 运行 ng update 后，我的所有组件都丢失了 debounceTime 导入.但我手动放回了它，但这并没有解决问题. example.component.ts import { debounceTime
..
RXJS 中的 AsyncSubject 有什么意义?
RxJS 的文档定义了 AsyncSubject 如下: AsyncSubject 是一个变体，其中只有 Observable 执行的最后一个值被发送给它的观察者，并且只有在执行完成时才发送. 我不知道在哪里/为什么我需要使用这个主题变体.有人可以提供一个解释或一个真实世界的例子来说明它为什么存在和它的优点吗? 解决方案 看起来它对于获取和缓存(一次性)资源很有用，因为通常 h
..
RXJS Observable doSomething onComplete
我想使用 RXJS Observable.基本上它工作正常，但我不仅需要在 observer.next() 和 observer.complete() 被调用时做出反应.如何获得 RXJS Observable 的 OnComplete 事件?在我看来，RXJS 文档令人困惑. 导出类服务{myMethod():Observable{return Observable.create((obser
..
RxJS 订阅者取消订阅与完成
我正在阅读 RxJS 文档，并希望确保我了解 Subscriber.unsubscribe() 和 Subscriber.complete() 之间的区别.> 假设我有一个 observable，有两个订阅者，subscriber1 和subscriber2.如果subscriber1 对他们的订阅调用unsubscribe，它将不再收到来自observable 的通知，但subscriber2
..
RxJS 1 数组项转换为单项序列 - 运算符
鉴于这样的可观察性 Rx.Observable.of([1,2,3,4,5]) 它发出一个单个项目(即一个数组)，操作符是什么，它将把这个 observable 转换成一个发出 5 个单个项目(或任何数组由)? 示例在 .of 上，但是通过 promise 获取数组也是一样的，可能还有很多其他示例.不建议将 of 替换为 from 解决方案 我想不出现有的操作符可以做到这一点，但
..
Angular - 在所有 HTTP 重试失败后捕获错误
我正在使用 Angular 服务从我的 API 获取数据.我实现了重试功能，以防获取数据失败.现在我需要在所有重试都耗尽时处理错误，但我无法捕捉到它. 以下是我的代码， public getInfoAPI(category:string, id:string = "", page:string = "1", limit:string = "10"){var callURL : string
..
执行http请求时带有多个forkjoin的rxjs
我正在执行一些 http 请求并使用 rxjs 来成功通知结果: getReportings(departmentId: number): Observable{返回 Observable.forkJoin(this.http.get('/api/members/' + DepartmentId).map(res => res.json()),this.http.get('/api/repor
..
等待 observable 在 foreach 内订阅结束
我正在迭代一个对象数组，每次迭代我都运行一个 observable.subscribe，我如何确保所有订阅都已完成，以便我可以调用另一个函数? 这是函数 calculaSimulacoesPorInscricao(){让 lista = ["2019-01-01","2020-02-02","2021-01-01","2022-01-01","2023-01-01"];this.clien
..
RxJs 订阅后，Angular 2 从服务返回数据不可用
在我的 map.service 中，我是这样编码的 loadAdminDataDiv(): Observable{返回 this.http.get("static/data/data.json").map(this.extractData);}私人提取数据(res){如果(res.status = 300){throw new Error('错误的响应状态:' + res.status);}//
..
Angular 5 从服务到组件再到模板获取数据的数组问题
尝试在模板 HTML 中显示从组件到服务调用的数据，该调用调用并返回 API，但出现此错误 错误错误:找不到类型为“object"的不同支持对象“[object Object]".NgFor 仅支持绑定到可迭代对象，例如数组. HTML {{item.name}} 组件 测试:任何；t
..
RxJS5 随着时间的推移发出数组项并永远重复
我想随着时间的推移发出数组项(每次发出之间有 1 秒的间隔)，当所有项都发出后，一遍又一遍地重复. 我知道怎么做，但我想知道是否有比 .. 更简洁的东西. const MY_ARRAY = ['one','two','three'];const item$ = Rx.Observable.interval(1000).take(MY_ARRAY.length).repeat().map(x
..
给 BehaviorSubject 初始值 - 值是一个 Observable
我知道我不能给 BehaviorSubject 一个 Observable 值，但我需要一种方法来解决这个问题.在应用程序初始化时，我正在获取当前用户(如果存在)，并且我需要为 BehaviorSubject 提供该潜在值.所以我的服务代码是这样的: private user = new BehaviorSubject(this.getUser());公共用户 $ = this.user.asO
..
使用 .map 转换 Observable
我在转换 observable 时遇到问题.详情如下: 我有这样的数据 [{'firstName': '约翰','lastName': '现金',“年龄":20}]; 然后我从api获取这些数据: public getData(): Observable{返回 this.http.get('xxx').地图(响应 =>响应.json());} 然后，我想订阅这个: this.se
..