如何模拟 RxJs 6 计时器?
我们最近从 Angular 5 更新到了 Angular 6，以及 RxJs 6.作为迁移的一部分，计时器的使用已从: Observable.timer() 到 timer() 在我们的测试中有很多地方我们使用以下模式模拟计时器可观察对象. let timerObserver: Observer;beforeEach(() => {spyOn(Observable, 'timer').a
..
rxjs6相关内容
带有函数返回 Observable 和异步管道的模板绑定
注意这是的简化问题带有 Observable 异步管道问题的 Angular 模板绑定 模板: {{foo()$ |异步}} 源代码: import { Component } from "@angular/core";从“rxjs"导入 { BehaviorSubject, of, Observable };import { tap, delay, map, switc
..
如何正确链接 rxjs 6 observables?
任何建议，如何以更承诺链的风格重写?: this.apiService.sendPutRequest('/api/users/activate', usrObj).pipe(地图(() => {return this.apiService.sendGetRequest('/api/users/' + this.currentUserId).pipe(地图(数据=> {返回 this.setAct
..
TypeScript 模块增强
我有可观察的扩展.它工作得很好，但现在我已经用 typescript 2.7.2 更新到了 angular 6. import { Observable } from 'rxjs/Observable';从 './base-component' 导入 { BaseComponent };从“rxjs/订阅"导入{订阅}；从'rxjs'导入{订阅}；声明模块'rxjs/Observable'{导出
..
RXJS 6:新版本的HttpInterceptor
我正在将 rxjs_compat 添加到我的项目中，以便迁移到 v6 的库. 然而，用于全局错误处理的现有 HttpInterceptor 不再编译.不知道该去哪里.各种都试过了.尝试过的所有方法都出现类型不匹配. import { Injectable } from "@angular/core";进口 {HttpEvent,Http拦截器，HttpHandler，请求，HttpResp
..
我没有得到带有间隔、switchMap 和 map 的 angular 6 的 rxjs 6
我想将我的 rxjs 代码更新为 6 我不明白. 在我每 5 秒轮询一次新数据之前: import { Observable, interval } from 'rxjs';import { switchMap, map } from 'rxjs/operators';var result = interval(5000).switchMap(() => this._authHttp.ge
..
错误:无法解析“rxjs/add/operator/map"
这是 app.module.ts 我已经尝试在不同的项目中完成地图的导入并且它工作正常，但在这个项目中它不起作用. import { BrowserModule } from '@angular/platform-browser';从'@angular/core' 导入 { NgModule };从“@angular/http"导入 {HttpModule}；从 './app.compon
..
在 Angular 中使用 shareReplay(1) - 仍然调用 http 请求?
我创建了一个演示(ng-run)我有一个调用 Http 请求的按钮. 当按钮被点击时，我调用这个方法: public getData(){this._jokeService.getData().subscribe();} 依次调用它(从服务中): public getData() {返回 this.http.get(API_ENDPOINT).pipe(shareReplay(1))
..
ThrottleTime 操作员的配置参数如何工作?(油门配置)
我已经阅读了 throttleTime 文档，但我不明白完全操作符. 我知道 throttleTime(1000) 是如何工作的.事件到达后，它将跳过所有后续事件 1 秒，然后再次开始此过程. 我难以理解的是 ThrottleConfig 究竟是如何工作的，它是操作符的第三个参数. throttleTime(持续时间:数量，调度程序:SchedulerLike = 异步，config
..
为什么我要使用 RxJS interval() 或 timer() 轮询而不是 window.setInterval()?
用例:每分钟(60000 毫秒)调用一个函数，该函数分派商店操作以获取商品的 lastUpdated 状态，根据响应和过滤，更新商店，并且更新的存储被读取为可观察的并显示在视图中).只要网络应用程序处于打开状态(无限期)，这就会发生. 目前，我正在使用这个: this.refreshDate = window.setInterval(() =>this.store.dispatch(new
..
如何获得“Observable.of([]);";去工作?
Observable.of([]); 的正确表达式和导入是什么? import { of } from 'rxjs'; 对我不起作用. 解决方案 从 RxJS 6 开始，您应该直接从 'rxjs' 导入所有“创建"可观察对象(假设您有 路径图 在捆绑您的应用程序时设置).> 更详细的解释:https://github.com/ReactiveX/rxjs/blob/master/M
..
我是否需要在 ngOnDestroy 中使用 `complete()` takeUntil Subject?
为了避免组件内部的 Observable 内存泄漏，我在订阅 Observable 之前使用了 takeUntil() 运算符. 我在我的组件中写了这样的东西: private unsubscribe$ = new Subject();ngOnInit(): 无效 {这个.http.get('测试').pipe(takeUntil(this.unsubscribe$)).subscribe
..
升级到 Angular 10 - 修复 CommonJS 或 AMD 依赖项可能导致优化救助
我正在尝试将我的 angular 9 应用程序升级到 angular 10 版本，但在升级后低于警告 rxjs\BehaviorSubject.js 依赖于 rxjs-compat/BehaviorSubject 知道如何解决这个问题吗? 解决方案 当您使用随 CommonJS 打包的依赖项时，可能会导致 更大更慢的应用程序 从版本 10 开始，Angular 现在会在您的构建引
..
将应用程序更新到 Angular 7 和 RxJS 6.3.3 后 Observable 的问题
我将我的应用程序更新到了 Angular 7 和 RxJS 6.3.3，但在更改我的代码时遇到了问题.我真的需要这方面的帮助，因为我找不到谷歌或堆栈溢出的解决方案. 我的进口: import { Observable, of } from 'rxjs';从'rxjs/operators'导入{地图，catchError}；从'@angular/core'导入{可注入，注入，可选，注入令牌}
..
如何使用 RxJS 在 Angular 6 中发出一系列 http 请求
我一直在网上寻找解决方案，但找不到适合我的用户案例的任何解决方案.我正在使用 MEAN 堆栈(Angular 6)并且我有一个注册表单.我正在寻找一种对 API 执行多个 HTTP 调用的方法，每个调用都依赖于前一个调用的返回结果.我需要看起来像这样的东西: firstPOSTCallToAPI('url', data).pipe(结果1 =>secondPOSTCallToAPI('url',
..
错误 TS2339:“Observable<boolean>"类型上不存在属性“partition"
以前我使用 rxjs-5，我使用 observable.partition 如下: const [isTiming$, isNotTiming$] = this.store.select(state => state.tetris.isTiming).partition(value => value); 将 angular 升级到 8 后 rxjs 升级到 rxjs-6 开始抛出以下错误:
..
将应用程序更新到 Angular 7 和 RxJS 6.3.3 后 Observable 的问题
我将我的应用程序更新到了 Angular 7 和 RxJS 6.3.3，但在更改我的代码时遇到了问题.我真的需要这方面的帮助，因为我找不到谷歌或堆栈溢出的解决方案. 我的进口: import { Observable, of } from 'rxjs';从'rxjs/operators'导入{地图，catchError}；从'@angular/core'导入{可注入，注入，可选，注入令牌}
..
如何修复"“WheelEvent"类型不存在属性“wheelDelta"升级到 angular 7，rxjs6 时?
我正在使用 rxjs6 升级到 angular7:在 mouseWheelEvent 类型中我得到 “属性 'wheelDelta' 在类型 'WheelEvent' 上不存在". 对于 wheelDelta，我们有其他选择吗? mouseWheelFunc(event: MouseWheelEvent): void {//var event = window.event ||事件;//旧
..
循环数组并为 Observable 中的每个 id 返回数据
使用 RxJS v6 从子集合中为循环中的每个项目检索数据具有挑战性.无法迭代从 HTTP 调用中检索到的 throw 数组.合并映射仅对需要对所有数组项执行此操作的单个项执行. 我已经坚持了 3 天.我什么都试过了.问题是新的管道语法虽然为您提供了组织代码的简洁方法，但没有简单的方法来循环抛出数据集合.无法使用 map javascript 函数，因为它在 observable 之外并且返
..
转换为函数时无法编译代码
我有以下可以正常工作的代码. public createData(data:Data):Observable{console.log('联系服务器在 '+this.API_URL +this.NEW_DATA_URL +" with data "+data+ " with httpOptions "+httpOptions.withCredentials + ","+httpOptions.h
..