ngrx-连锁两个store.select切片
在我的Todo Cmp中，我有此代码 this.todoListGroup$ = this.ngrx.select(fromRoot.getTodos) .flatMap((todos: Todo[]) => { console.log(todos) this.todos = todos this.ngrx.select(fromRoo
..
rxjs相关内容
在单元测试中模拟带有参数的ngrx存储选择器(角度)
我正在尝试为Angular中的服务编写单元测试. 我想模拟ngrx的store.select函数，以便测试服务对存储选择器返回的不同值的反应.我希望能够分别模拟每个选择器. 我的主要问题是如何模拟参数化选择器. 我以前使用过一个BehaviourSubject，它映射到select函数，但这不允许您为不同的选择器返回不同的值.它不可读，因为您在嘲笑哪个选择器并不明显. 选项1:使
..
如何在ngrx效果中进行http轮询
我有这种效果，我正在尝试使用计时器每x秒轮询一次数据.但是我无法弄清楚计时器应该如何与数据流交互.我尝试在顶部添加另一个switchMap，但是后来我无法将操作和有效负载传递给第二个switchmap.有什么想法吗? 我查看了这篇文章但是我的情况有些不同.我正在通过需要访问的操作传递有效负载，并且正在使用ngrx 6. @Effect() getData = this.actions$
..
为什么动作不会在第二次运行时触发“效果"?
效果: @Effect() loadDocsEffect$ = this.actions$.pipe( ofType(myActionTypes.LoadDocs), mergeMap(action => this.myService.getDocs()), map(data => new LoadDocsSuccess(data)), catchErro
..
更新ngrx/store中的对象
我在Angular 2应用中使用@ ngrx/store. 我的商店中有一个Book对象的列表.我想更新其中一个对象的字段.我也碰巧有一个我要更新的Book实例的Observable(例如selectedBook). 要进行更新，我打算使用UpdateBookAction和新Book的有效负载调用reducer.因此，我通过订阅selectedBook然后调用Object.assign
..
浏览器页面刷新期间Angular 5 Ngrx状态丢失
我对angular 5和Ngrx并不陌生，有些我设法实现了登录功能，一旦登录成功，我就将用户带到了仪表板.但是，如果刷新页面，则用户状态似乎丢失了.如何在页面重新加载时使用户状态持久化? 解决方案 即使页面重新加载，如何使用户状态持久化? 作为@ user184994提及的 状态仅保存在内存中.如果您希望它在页面刷新之间保持不变，请转到LocalStorage或sessionS
..
在ngrx中获取当前状态
此处是在ngrx中获取当前状态的解决方案.这个例子很简单-您只需使用take(1).但是在take的rxjs文档中它说: 从的开始处返回指定数量的连续元素. 可观察的序列 取第一个值如何获取当前状态(即最后一个值)? 此外，在使用Subject进行单元测试时，我还无法模拟这种行为. 解决方案 ngrx-store是length=1的ReplaySubject，这意味着仅1
..
重新连接Angular和rxjs中的websocket?
我有一个基于ngrx/store(v2.2.2)和rxjs(v5.1.0)的应用程序，该应用程序使用可观察的方法侦听Web套接字中的传入数据.当我启动应用程序时，我会完美地接收到传入的数据. 但是过了一会儿(更新很少出现)，连接似乎丢失了，我再也没有收到传入的数据了.我的代码: 服务 import { Injectable, OnInit } from '@angular/cor
..
RXJS Pipe中未触发tap()
尽管我更喜欢第一个方法，但我必须采取相同的方法.但是第一种方法似乎行不通. (tap()未触发) // does not work this.actions$.pipe( ofType(LayoutActions.Types.CHANGE_THEME), takeUntil(this.destroyed$), tap(() => { console.l
..
Angular 2更新全局状态是更新特定状态的副作用
我想设置全局状态，同时还要从api请求数据并将其存储在该状态中，但要存储在全局状态以外的其他位置. 我称这种效果(models.effects.ts): @Effect() models$: Observable = this.actions$ .ofType(GET_MODELS) .switchMap(() => this.modelsApi.getMode
..
#ngrx示例中的SwitchMap与MergeMap
以下是Ngrx示例中的代码: https: //github.com/ngrx/example-app/blob/master/src/effects/book.ts 我的问题是，为什么在第一个@Effect中，它使用switchMap，而其他人使用mergeMap.那是因为第一个@Effect正在处理网络，并且使用switchMap您可以取消先前的网络请求(如果正在运行)? @Effect
..
ngrx效果错误处理
关于@ngrx效果，我有一个非常基本的问题:如何忽略在效果执行期间发生的错误，以免影响以后的效果执行? 我的情况如下:我有一个动作(LOGIN)和一个监听该动作的效果.如果此效果内发生错误，我想忽略它.错误发生后第二次发送LOGIN时，应再次执行效果. 我第一次尝试这样做是 @Effect() login$ = this.actions$ .ofType('LOG
..
提前进行ng-bootstrap:如何处理Observable< Person []> ;；而不是Observable< string []>
我有一个新手Angular/Typescript问题. 我遵循了 ng-bootstrap typeahead 并且我决定将Wikipedia调用替换为提供以下GET调用的自定义REST服务: 获取/person/name/{name} 并返回与姓名匹配的人员列表，其中每个人都是: Person(id:long, name:string, surname:string)
..
为什么要在Observable函数上调用.call()?
我是Angular的一个相对入门的人，我正在努力了解我从ng-bootstrap项目中读取的一些资料. 可在此处找到源代码. 我对ngOnInit中的代码感到非常困惑: ngOnInit(): void { const inputValues$ = _do.call(this._valueChanges, value => { this._userInput = v
..
nestjs中的Observables-异步读取文件
我正在尝试一个用例，它以异步方式读取json文件并将其作为响应(作为rxjs可观察的数据)发送出去.这是我使用的服务 import { logger } from './../../shared/utils/logger'; import { Injectable } from '@nestjs/common'; import * as fs from 'fs'; import * as
..
属性"connect"在类型"Observable< any>"上不存在| RXJS组播
我有一个Observable，它产生单播值(对于所有观察者都是如此).但是，当我要使用RxJs多播运算符转换为多播时，它将返回以下错误. “可观察"类型不存在“连接"属性 单播(工作代码)- let source4$ = interval(1000).pipe(take(4)); source4$.subscribe(val => { console.log(`Obse
..
角度2-打字稿:TS2322:无法将“订阅"类型分配给“可观察< MouseEvent>"类型
我正在使用该插件的click-outside指令-> http://embed.plnkr. co/v7BMUv/ 我的TS编译器抛出以下错误: TS2322:无法将“预订"类型分配给“可观察"类型. 订阅类型中缺少属性"_isScalar". TS2339类型“可观察"的属性“取消订阅"不存在. 我的tsconfig.json: { "compileOnSav
..
Angular2:鼠标事件处理(相对于当前位置的移动)
我的用户应该能够通过鼠标在画布中移动(或旋转)对象.发生鼠标事件时，屏幕坐标用于计算到最后一个事件的增量(方向和长度).没什么特别的... 鼠标移下(获取第一个坐标) mousemove(获取第n个坐标，计算deltaXY，通过deltaXY移动对象) mouseup(与第2步相同，并停止mousemove和mouseup事件处理) 在这一系列事件之后，应该可以重复执行相同的操作.
..
猫鼬光标:http集合中的批量请求
我遇到一个与rxJS和大量集合中的大量HTTP请求(1M +文档)相关的问题 我有以下代码，逻辑很简单.我将集合中的所有文档推送到allplayers数组，并一次向API发出20个批量HTTP请求(猜测您了解其局限性)，因此，代码可以正常工作，但我想是时候从此重构它了: const cursor = players_db.find(query).lean().curso
..
最好的方式以无反应的方式从mongodb集合中查询所有文档，而不会溢出RAM
我想以被动方式查询集合中的所有文档.的 collection.find()方法mongodb nodejs驱动程序返回一个游标，该游标触发集合中找到的每个文档的事件.所以我做了这个: function giant_query = (db) => { var req = db.collection('mycollection').find({}); return Rx.O
..