Observable 继续调用 API 并根据条件更改参数
我已经阅读了 Rx.js repeat 文档以试图找出答案如何根据从 API 收到的响应继续调用 api.我正在调用一个 API，它一次只能发回 2k 条记录.API 会发回一个值供我发送，以便我可以继续接收记录，直到它们返回完成值. 所以流程如下: 发出一个 GET 请求一个查询参数 reqMode='': 使用包含 reqMode 和 value 或 done 的最后一个数组检索
..
rxjs5相关内容
将多个可观察数组组合成新的对象数组
我有 3 个如下所示的可观察数组. persons = [{"firstName":"约翰","lastName":"公共","locationID":"1",“部门ID":“100"},{"firstName":"sam","lastName":"史密斯","locationID":"2",“部门ID":“101"}]部门 = [{“部门ID":“100"，“名称":“开发"},{“部门ID"
..
RxJS 重构嵌套映射语句
我有一个使用 @angular/http 从 API 加载数据的服务.我想使用此数据为我的 Components 创建检索到的数据的投影. 因此我写了以下代码: getById(id: string) {返回 this.http.get(`https://my-api.io/${id}`).map(response => response.json()).map(合同=>contract.
..
RxJS 5 中的共享重放
根据 RxJS 5 MIGRATION.md 看起来 shareReplay() 已被删除. 为什么? .publishReplay(1).refCount() 是否忠实地复制了行为?基本上，我需要向任何新订阅者重放最新的单个数据集. 解决方案 简短的回答:引用布莱什爵士的话: RxJS 5 试图解决的问题是 ConnectableObservables应该是“可重新连接的"
..
展平嵌套的 Observable
我被困在嵌套的可观察地狱中，可以用手做. 我有以下代码块 return this.findUser(term).map( users => {return users.map( user => this.getLastLogin(user.user_id).map( last_login => {user.last_login = last_login;返回用户；}));}); find
..
试图理解 RxJS 导入
我很难弄清楚这个导入语句究竟是如何工作的(在一个用 Typescript 编写的 Angular 应用程序中): import 'rxjs/add/operator/toPromise'; 我知道 rxjs 被映射到 SystemJS 配置文件中相应的 node_modules 子文件夹，但后来我卡住了.我看到有一个 index.js 文件，但我不知道这是否或如何帮助解决 add/operat
..
如何在 Angular 中等待守卫
如果我在一条路线上指定三个守卫，似乎所有守卫都会立即被评估. {path: '', component: OptionsComponent, canActivate: [GuardOne, GuardTwo, GuardThree]} 我遇到的问题是我不希望 GuardTwo 在 GuardOne 完成之前运行.有什么办法可以做到这一点吗? 解决方案 我认为这在 4.1.3 中
..
使用 rxjs5 获取 BehaviorSubject 当前值的简单方法
之前在 rxjs4 中，BehaviorSubject 中有一个方法叫做:getValue() (此处的文档). rxjs5中不再存在此方法. 因此，我发现获得 BehaviorSubject 值的唯一解决方案是: let 值；myBehaviorSubject.take(1).subscribe((e) => value = e); 这段代码同步运行(我不完全明白为什么，但它确实
..
“异步"管道不呈现流更新
尝试使用 async 管道通过 angular 2 组件中的流在窗口调整大小时呈现窗口大小: 尺寸:{{size$ |异步 |json}}
const windowSize$ = new BehaviorSubject(getWindowSize());Observable.fromEvent(window, 'resize').map(getWindowSize).subscr
..
Observable forkJoin 不触发
我正在尝试在两个 Observable 上使用 forkJoin.其中一个以流的形式开始...如果我直接订阅它们，我会收到回复，但 forkJoin 不会触发.有什么想法吗? private data$: Observable;私有状态$:Observable;private queryStream = new Subject();....this.data$ = this.queryStrea
..
为什么我要使用 RxJS interval() 或 timer() 轮询而不是 window.setInterval()?
用例:每分钟(60000 毫秒)调用一个函数，该函数分派商店操作以获取商品的 lastUpdated 状态，根据响应和过滤，更新商店，并且更新的存储被读取为可观察的并显示在视图中).只要网络应用程序处于打开状态(无限期)，这就会发生. 目前，我正在使用这个: this.refreshDate = window.setInterval(() =>this.store.dispatch(new
..
我将如何使用 `do` 作为 RxJS 的可出租操作符?
RxJS 5.5 允许抓取可出租的操作符并像这样进行管道传输: import { ajax } from 'rxjs/observable/dom/ajax'import { catchError, map, retry } from 'rxjs/operators'ajax.getJSON('https://example.com/api/test').管道(重试(3, 1000),地图(fe
..
SystemJS 为 rxjs 加载许多文件
我有以下 systemjs.config.js(基于我在互联网上找到的一些示例): (函数(全局){系统配置({路径:{//路径作为别名'js:': 'js/',},//map 告诉系统加载器去哪里找东西地图: {//我们的应用程序在 app 文件夹中应用程序:'应用程序'，//角度包'@angular/core': 'js:angular2/core.umd.js','@angular/com
..
RxJs 5 share() 操作符是如何工作的?
我不是 100% 清楚 RxJs 5 share() 操作符是如何工作的，请看这里 最新文档.用于问题的 Jsbin 此处. 如果我创建一个 0 到 2 系列的 observable，每个值间隔一秒: var source = Rx.Observable.interval(1000).take(5).do(函数(x){console.log('一些副作用');}); 如果我为这个 obs
..
如何从`Rx`(非角度)导入`Observable`
我正在使用 SystemJS 将我的 es2015 项目加载到浏览器中. 这是我做的 从'rxjs/Rx'导入{Observable}；const button = document.querySelector('button');const start$ = Observable.fromEvent(button, 'click'); 在这种情况下，Observable 是 undef
..
Rx.Subject 丢失事件
谁能解释一下这 3 个变体之间的区别? http://jsfiddle.net/8vx2g3fr/2/ 首先作为 expect 工作，所有事件都被处理. 但是第二个输掉了最后一个事件(3) 第三次输掉第二场比赛 (2) 你能帮我理解问题是什么以及如何让第三个变体处理所有事件吗? 1 let bs = new Rx.Subject();bs.subscribe(v=>{
..
如何获得“Observable.of([]);";去工作?
Observable.of([]); 的正确表达式和导入是什么? import { of } from 'rxjs'; 对我不起作用. 解决方案 从 RxJS 6 开始，您应该直接从 'rxjs' 导入所有“创建"可观察对象(假设您有 路径图 在捆绑您的应用程序时设置).> 更详细的解释:https://github.com/ReactiveX/rxjs/blob/master/M
..
我如何解决这个“主题错误地扩展了 Observable"?TypeScript 2.4 和 RxJS 5.x 中的错误?
当我编译时，我在 RxJS 声明文件中收到以下编译器错误: node_modules/rxjs/Subject.d.ts(16,22): 错误 TS2415: Class 'Subject'错误地扩展了基类“Observable".物业“电梯"的类型是不兼容的.输入'(运算符:运算符)=>可观察的'不可分配给类型 '(操作符:操作符)=>可观察到的 R '.输入'Obser
..
尝试阻止订阅两次时出现 ObjectUnsubscribedError
我有一个服务和一个使用它的组件: PagesService PagesListComponent 在 PagesService 中，我有一个 Pages 数组.我通过他们都订阅的 BehaviorSubject 通知数组中的更改. PagesService 在 bootstrap 中提供，只共享一个实例.那是因为我需要保留数组，而不是每次需要时都下载页面. 代码如下:
..
Rxjs 5 - 简单的 Ajax 请求
我正在尝试从一个简单的 ajax 请求中获取值，但我不明白该怎么做.代码如下: Rx.Observable.ajax({ url: 'https://jsonplaceholder.typicode.com/posts', 方法: 'GET', responseType: 'json' }).subscribe(function(data) { return data.response; });
..