rxjs相关内容
export 声明类 EventEmitter扩展主题{/*** 创建一个 [EventEmitter] 的实例,它依赖于 [isAsync],* 同步或异步传递事件.*/构造函数(isAsync?:布尔值);发射(值:T):无效;/*** @deprecated - 使用 .emit(value) 代替*/下一个(值:任何):无效;subscribe(generatorOrNext?: a
..
当我从头开始创建一个 observable 并且有观察者错误,然后完成时,订阅的完成部分永远不会被调用. var 观察者 = Rx.Observable.create(function(observer){observer.onError(new Error('no!'));观察者.onCompleted();})观察者.订阅(function(x) { console.log('succeed
..
我正在尝试使用拦截器来处理 http 错误并重试特殊错误状态,在我的例子中是状态代码 502. intercept(request: HttpRequest, next: HttpHandler): Observable>{返回 next.handle(request).管道(重试时(错误 => {返回错误.管道(mergeMap(error => (error.status === 502)
..
我有一个以页面为单位返回数据的服务.对一页的响应包含有关如何查询下一页的详细信息. 我的方法是返回响应数据,然后如果有更多可用页面,则立即将延迟调用连接到相同的可观察序列. function getPageFromServer(index) {//返回测试用例的虚拟数据返回 {nextpage:index+1, data:[1,2,3]};}函数 getPagedItems(index)
..
我很好奇我应该如何取消订阅我的所有订阅.我知道 takeWhile() 和 takeUntil().我发现 takeUntil() 对我更有用. 据我了解,takeWhile()在我们拿到数据后生效.然后取消订阅,直到组件被销毁. 使用 takeUntil() 和不使用它有什么区别.只是 .unsubscribe()? 不使用 takeUntil() ngOnInit() {t
..
我有一个服务,它从我的许多 Angular 2 组件中多次使用.它从 Web API 获取客户数据并返回一个 Observable: getCustomers() {返回 this.http.get(this.baseURI + this.url).map((r: 响应) => {让 a = r.json() 作为 Customer[];返回一个;});} 我将此服务注入到我的根组件中,并且在
..
我有一些可观察的.我需要知道哪个触发了订阅. Observable.combineLatest(this.tournamentsService.getUpcoming(),this.favoriteService.getFavoriteTournaments(),this.teamsService.getTeamRanking(),(锦标赛,最喜欢的,球队)=>{//是什么触发了 combine
..
嗨,我正在尝试学习有关 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
..
我想按可观察字段对事物列表进行排序,但无法围绕可观察对象进行排序以使其正常工作.有人知道如何实现这一目标吗? 最初的情况是这样的: Thing[] things;接口东西{名称:Observable} {{东西名称 |异步}} 因为我显然没有正确描述我的问题:我想对事物列表进行排序的字段是一个 Observa
..
这是 app.module.ts 我已经尝试在不同的项目中完成地图的导入并且它工作正常,但在这个项目中它不起作用. import { BrowserModule } from '@angular/platform-browser';从'@angular/core' 导入 { NgModule };从“@angular/http"导入 {HttpModule};从 './app.compon
..
我已经用 RxJS 试验了两个星期了,虽然原则上我喜欢它,但我似乎无法找到并实现管理状态的正确模式.所有文章和问题似乎都同意: Subject 应该尽可能避免,以支持通过转换来推送状态; .getValue() 应该完全弃用;和 .do 也许应该避免除了 DOM 操作? 所有这些建议的问题在于,除了“您将学习 Rx 方式并停止使用 Subject"之外,似乎没有任何文献直接说明您应
..
我的用例如下:我得到事件,这些事件有时会突然发生.如果发生突发,我只需要处理一次.去抖就是这样做的. 然而,去抖动只给我一个突发的最后一个元素,但我需要知道突发中的所有元素才能聚合它们(使用平面图). 这可以通过定时窗口或缓冲区来完成,但是,这些是固定间隔,因此缓冲区/窗口超时可能发生在突发的中间,因此将突发分成 2 部分而不是 1 部分来处理. 所以我想要的是像 ..事件:一
..
我在订阅未触发的 observable 时遇到问题. 我有一个使用侧导航布局指令的布局,如下所示: 首页关闭
..
我有两个 Angular2 组件需要通过服务共享数据: @Injectable()导出类 SearchService {private searchResultSource = new Subject()searchResult$ = this.searchResultSource.asObservable()setSearchResults(_searchResult: string):
..
我用这个方法构建了一个简单的确认对话服务(Angular 2): confirm(body?: string, title?: string): Subject{this.confirmation = new Subject();//...在此处显示对话框...“你确定吗?"返回 this.confirmation;}_onYesClicked() {//... 关闭对话框this.confir
..
我有 3 个依赖的 Rest API 资源(比如 observables),如下所示: 第一个 observable 将一个项目作为用户数组生成,如下所示: getUsers(): Observable[{“身份证":1,"name": "彼得",“姓氏":“史密斯"},{“身份证":2,"name": "约翰",“姓氏":“韦恩"},...] 2nd observable 可用于获取分
..
这主要是 RxJs 最佳实践/方法问题,因为我的 POC 代码有效,但我是 RxJs 的新手. 问题归结为 .subscribe() 与 .publish().connect(),因为它们似乎都在做同样的事情. 在我的 angular2 应用程序中,我有一个按钮调用一个函数来注销用户,它调用我的服务中的一个函数来执行一些服务器端操作并返回一个 URL 以将用户重定向到.为了发起请求,我
..
我有一个 Observable 数组,我想按名称过滤/查找项目.当我尝试使用过滤器选项时,它说 ProjectService.ts import { Injectable } from '@angular/core';从“../classes/project"导入{项目};从 'rxjs/Observable' 导入 { Observable };导入 'rxjs/add/observab
..
我正在迁移到 rxjs@5.5.2 并使用可出租的运算符...我还更新了 Observable 静态方法.我想知道 Observable.throw 和 import 'rxjs/add/observable/throw'; 的对应物是什么. 我应该导入丑陋的_throw吗? import { _throw } from 'rxjs/observable/throw'; 或者有更
..
我的 Angular 2 应用程序在一个服务中有 2 个方法(GetCategories() 和 GetCartItems()),并且这两个方法都返回 Observables. 为了从我的组件中依次调用这两个方法,我编写了以下代码: ngOnInit(){this.appService.GetCategories().subscribe((数据) => {this.appService.
..