rxjs相关内容

如何取消订阅 Angular 2 中的 EventEmitter?

export 声明类 EventEmitter扩展主题{/*** 创建一个 [EventEmitter] 的实例,它依赖于 [isAsync],* 同步或异步传递事件.*/构造函数(isAsync?:布尔值);发射(值:T):无效;/*** @deprecated - 使用 .emit(value) 代替*/下一个(值:任何):无效;subscribe(generatorOrNext?: a ..
发布时间:2022-01-01 22:29:57 其他开发

使用 RxJs 将分页请求转换为 Observable 流

我有一个以页面为单位返回数据的服务.对一页的响应包含有关如何查询下一页的详细信息. 我的方法是返回响应数据,然后如果有更多可用页面,则立即将延迟调用连接到相同的可观察序列. function getPageFromServer(index) {//返回测试用例的虚拟数据返回 {nextpage:index+1, data:[1,2,3]};}函数 getPagedItems(index) ..
发布时间:2022-01-01 22:29:36 前端开发

Angular 4 - 取消订阅的最佳方式

我很好奇我应该如何取消订阅我的所有订阅.我知道 takeWhile() 和 takeUntil().我发现 takeUntil() 对我更有用. 据我了解,takeWhile()在我们拿到数据后生效.然后取消订阅,直到组件被销毁. 使用 takeUntil() 和不使用它有什么区别.只是 .unsubscribe()? 不使用 takeUntil() ngOnInit() {t ..
发布时间:2022-01-01 22:29:29 其他开发

什么触发了 combineLatest?

我有一些可观察的.我需要知道哪个触发了订阅. Observable.combineLatest(this.tournamentsService.getUpcoming(),this.favoriteService.getFavoriteTournaments(),this.teamsService.getTeamRanking(),(锦标赛,最喜欢的,球队)=>{//是什么触发了 combine ..
发布时间:2022-01-01 22:29:11 其他开发

Observable 上不存在地图使用角度 6.0.0 和 rxjs 6.1.0
嗨,我正在尝试学习有关 angular 的教程,但该教程是在 9 月制作的.我相信这个人使用了 angular-cli 1.3.2.我不确定他使用的是哪个版本的 rxjs.我在 rxjs 6.1.0 中使用 angular cli 6.0.0 和 angular 6. 我遇到了在 observable 上调用 .map 没有找到的问题.xxx/xxx/dataService.ts(19,14 ..
发布时间:2022-01-01 22:29:02 其他开发

Angular2 rxjs 按可观察字段排序(可观察)对象列表

我想按可观察字段对事物列表进行排序,但无法围绕可观察对象进行排序以使其正常工作.有人知道如何实现这一目标吗? 最初的情况是这样的: Thing[] things;接口东西{名称:Observable} {{东西名称 |异步}} 因为我显然没有正确描述我的问题:我想对事物列表进行排序的字段是一个 Observa ..
发布时间:2022-01-01 22:28:54 其他开发

错误:无法解析“rxjs/add/operator/map"

这是 app.module.ts 我已经尝试在不同的项目中完成地图的导入并且它工作正常,但在这个项目中它不起作用. import { BrowserModule } from '@angular/platform-b​​rowser';从'@angular/core' 导入 { NgModule };从“@angular/http"导入 {HttpModule};从 './app.compon ..
发布时间:2022-01-01 22:28:41 其他开发

如何在一个简单的 RxJS 示例中不使用主题或命令式操作来管理状态?

我已经用 RxJS 试验了两个星期了,虽然原则上我喜欢它,但我似乎无法找到并实现管理状态的正确模式.所有文章和问题似乎都同意: Subject 应该尽可能避免,以支持通过转换来推送状态; .getValue() 应该完全弃用;和 .do 也许应该避免除了 DOM 操作? 所有这些建议的问题在于,除了“您将学习 Rx 方式并停止使用 Subject"之外,似乎没有任何文献直接说明您应 ..
发布时间:2022-01-01 22:28:32 前端开发

RXJS:聚合去抖动

我的用例如下:我得到事件,这些事件有时会突然发生.如果发生突发,我只需要处理一次.去抖就是这样做的. 然而,去抖动只给我一个突发的最后一个元素,但我需要知道突发中的所有元素才能聚合它们(使用平面图). 这可以通过定时窗口或缓冲区来完成,但是,这些是固定间隔,因此缓冲区/窗口超时可能发生在突发的中间,因此将突发分成 2 部分而不是 1 部分来处理. 所以我想要的是像 ..事件:一 ..
发布时间:2022-01-01 22:28:18 其他开发

RxJS - .subscribe() 与 .publish().connect()

这主要是 RxJs 最佳实践/方法问题,因为我的 POC 代码有效,但我是 RxJs 的新手. 问题归结为 .subscribe() 与 .publish().connect(),因为它们似乎都在做同样的事情. 在我的 angular2 应用程序中,我有一个按钮调用一个函数来注销用户,它调用我的服务中的一个函数来执行一些服务器端操作并返回一个 URL 以将用户重定向到.为了发起请求,我 ..
发布时间:2022-01-01 22:27:30 其他开发

角度过滤器 Observable 数组

我有一个 Observable 数组,我想按名称过滤/查找项目.当我尝试使用过滤器选项时,它说 ProjectService.ts import { Injectable } from '@angular/core';从“../classes/project"导入{项目};从 'rxjs/Observable' 导入 { Observable };导入 'rxjs/add/observab ..
发布时间:2022-01-01 22:27:20 其他开发

rxjs 5.5.2 中的 Observable.throw 替换

我正在迁移到 rxjs@5.5.2 并使用可出租的运算符...我还更新了 Observable 静态方法.我想知道 Observable.throw 和 import 'rxjs/add/observable/throw'; 的对应物是什么. 我应该导入丑陋的_throw吗? import { _throw } from 'rxjs/observable/throw'; 或者有更 ..
发布时间:2022-01-01 22:27:11 其他开发