计算链中的其他运算符(而不是CombineLatest)可以避免冗余计算
我已经成功地使用RxJS将较大的Excel计算迁移到JS.当任何Excel公式使用多个输入时，任何输入数据均表示为Observable，随后的计算将使用.map和.combineLatest进行. 除一个问题外，此方法效果很好.这是一个简化的示例: 在两个不同的计算中使用三个输入(a$=1，b$=2，c$=3)(第一个是$ab = $a+$b = 3，第二个是$bc = $b+$c =
..
rxjs相关内容
使用哪个合并运算符来侦听单个源而不是第二个流源
所以我知道这个问题看似简单，但并不是那么简单. 我尝试过的所有运算符，例如combineLatest，concat和switchMap都会导致差异问题. 这就是挑战: var campaignSelected$ = this.store.select(store => store.appDb.uiState.campaign.campaignSelected) var campaign
..
Angular NgRx-仅在首次调用时才继续轮询服务的效果
我有一个应用程序，我刚刚在其中添加了NgRX，我希望使用效果来打开和关闭轮询. 示例大纲 我关注了这篇文章这似乎是一个好方法.我有一个此处的简化示例，其中大部分代码位于app.effects.ts. 与示例类似，除了使用新的createEffect工厂方法外，我还具有startPolling$，stopPolling$和continuePolling$的效果. 此外，我将d
..
订阅时进行ngrx轮询以刷新数据
上下文 我在相关应用程序中使用了以下库:Angular 4.x，ngrx 4.x，rxjs 5.4.x 在我的应用程序中，我能够从websocket中获取一些数据，但对于某些应用程序，我必须使用RESTful API.我正在通过ngrx在多个组件之间共享数据.现在，我根据创建，更新和删除等事件来重新获取数据. 我不希望对数据进行太多的并发修改，但是我确实需要一种手动或自动确保我的
..
RXJS等待所有可观测值完成并返回结果
我正在尝试创建一个RX流，该流将异步执行XHR调用列表，然后等待它们完成后再转到下一个调用. 为了帮助解释这一点，可以在普通的JS中这样写: try { await* [ ...requests.map(r => angularHttpService.get(`/foo/bar/${r}`)) ]; } catch(e) { throw e } //
..
为什么要对Http服务使用.takeUntil()而不是.take(1)?
上下文:我正在努力在一个环境中实现 @ ngrx/effects @ ngrx/store 项目并研究 问题:在 BookEffects类文件，第50行，为什么使用takeUntil(...)代替take(1)?在这种情况下，两者似乎都可以完成相同的事情. @Injectable() export class BookEffects { constructor(private actio
..
Angular rxjs Observable.timer不是导入功能
在我的有角度的应用程序中，我收到以下错误: 错误TypeError: rxjs_Observable__WEBPACK_IMPORTED_MODULE_4 __.Observable.timer不是 功能 在SwitchMapSubscriber.project(hybrid.effect.ts:20) 在SwitchMapSubscriber.push ../node_modules/rx
..
RxJs/NgRx-是否有一种方法可以“取消"邮件.延迟运算符之后的流
我正在使用NgRx在Angular应用程序中使用轮询方案. 为简化起见，我有类似以下内容的内容... public stopPolling$ = createEffect(() => this.actions$.pipe( ofType(actions.stopPolling), tap(_ => this.isPollingActive = f
..
如何在Angular 4中使用RxJS将props正确传递给组件?
这是我的组成部分: @Component({ selector: 'bc-goods-detail', template: ` good id: {{good?.id}}
..
调度上的Angular2 NGRX性能问题?
我一直在Angular2/CLI/NGRX中开发一个应用程序，直到最近为止一切都进行得很好.我注意到性能出现了相当大的峰值，特别是在同一容器内连续调度时. 例如，可以说我定义了以下内容: public appEnvironment$: Observable; public assessment$: Observable; publ
..
非规范化ngrx存储设置选择器?
我目前正在ngrx项目中使用某种复杂(较深)的结构.可以将其视为具有多个子对象级别的父对象数组.它在服务器端已标准化/扁平化，而我商店中的功能如下所示: rootObjs: { level1: { byId: { 'lvl1_1': {id: 'lvl1_1', label: '[Lvl 1]: 1', ui_open: true, child
..
如何处理减速器内的错误?
我有loggerService，我需要捕获reducer中的所有错误并将其通过我的服务发送到服务器. 我该怎么办?我知道reducer应该是一个纯函数，但是还有什么想法吗? 我需要添加reduser try catch case actions.GAMES_LOADED{ ...... try{} catch(err){
..
NGRX影响如何将参数传递给withLatestFrom运算符
在使用withLatestFrom时，我正在努力将参数传递给选择器，它是从加载动作有效负载中映射的 loadLocalSubServices$: Observable = this.actions$.pipe( ofType(LocalSubServiceTemplateActions.LocalSubServicesTemplateActionTypes.LoadLoc
..
从效果中分派多个动作:不同rxjs运算符之间的差异
http请求成功后，我需要从ngrx效果中调度多个操作. 似乎有几种方法行得通，有些则行不通，我不明白有什么区别. @Effect() loadUser = this.actions .pipe( ofType(campaignActions.type.LOAD_CAMPAIGN), map((action: us
..
传递/保留长管输掉值的理智方法
假设我有以下rxjs管道: start$.pip( map((id)=> {}), //I want to save the "id" value to be used in the end of the pipe map(...), switchMap(...), map(...), switchMap(...), map(...),
..
@ngrx中的效果中的连锁动作
在进行HTTP请求的效果中，我在一个接一个的链接动作上遇到了一些麻烦. 以下是效果代码: export class UserEffects { @Effect() update$: Observable = this.actions$.ofType(user.USERCHANGE).pipe( switchMap(data => thi
..
Angular2 + ngrx/store用于处理失败的HTTP请求
我想有一个简单的代码路径来创建和调度HTTP动作.我想做的是这样的: this.http.request(...) .map((res: Response) => res.json()) .catch((err: any) => err.json()) .map((payload: any) => { type: 'SUCCESS', payload }) .catch((p
..
RxJS可观察:订阅丢失了?
以下两个可观察的映射之间有什么区别? (如果以下代码中的某些内容对您来说很奇怪:它源于边做边学的业余爱好项目；我仍然在学习RxJS) 我有一个带有getter和构造函数的组件.两者都从应用程序的ngrx存储中读取信息，并提取一个字符串(name). getter和构造函数之间的唯一区别: getter用于HTML，它返回的可观察对象通过async管道发送，而构造函数中的可观察映射
..
等到两个Observables完成
我想在两个Observables返回值之后调用一个方法.我做了一些搜索，看来forkJoin是我想要的，但我无法使它正常工作.我知道这两个Observable都返回值，因为我在组件中其他每个地方分别使用数据，所以很明显我在做其他错误. 这是我尝试过的.我正在使用rxjs v6.4. forkJoin( this.store.pipe(select(fromStore.getAppo
..
@ ngrx/store订阅商店的一部分，并避免检测到对其他部分的更改
背景 我商店中的一个化简工具处理应用程序中选择的事物.该商店的界面(简称为app)如下所示: interface IApp { selectedProject: IProject; selectedPart: IPart; } 因此，我希望有一个仅在选择了不同的“项目"时才执行操作的订阅.我写了这样的东西: this.store.select('app')
..