RXJS - Angular - 取消订阅主题
如此主题中所述，“官方"在 Angular 5+ 中取消订阅 Observables 的解决方案通常是使用 takeUntil.到现在为止还挺好.我的问题是，如果我订阅的 Observable 实际上是一个主题，这也适用吗? 解决方案 一旦你对任何东西(Subjects 也是)调用 .subscribe() ，需要确保订阅被取消订阅..subscribe()> 处理有限的 Observa
..
observable相关内容
使用 rxjs 实现指数退避
Angular 7 docs 提供了 rxjs Observable 为 AJAX 请求实现指数退避: import { pipe, range, timer, zip } from 'rxjs';从'rxjs/ajax'导入{ajax}；import { retryWhen, map, mergeMap } from 'rxjs/operators';功能退避(maxTries，毫秒){回水管
..
“错误"消息:“typeof Observable"类型上不存在“属性"“from"
我正在尝试使用 RxJS 学习响应式编程.我试图使用 Observable.from() 方法从数组创建一个 observable，但出现错误: 'typeof Observable' 类型不存在属性 'from' 我使用 Angular CLI 搭建了一个 Angular 应用程序，所以包括 RxJS 包在内的所有依赖项都被正确导入. 在 app.component.ts 中，
..
输入'Observable'不可分配到类型“[]"
我对 Angular2/TypeScript 还很陌生，所以如果我犯了一些愚蠢的错误，请原谅.我想要做的是从 Select 下拉列表中我正在使用服务填充数据，该服务返回一个 JSON 数组. 这是我的代码: product-maintenance.component.ts从“@angular/core"导入{组件，OnInit}；从'../../_services/product-main
..
如何在Angular2中使用Observable通过id查找数组的元素
我决定使用 Observable 而不是 Http promises. 这就是我的 Promise 服务的样子: 导出类 MovieService {电影:电影[]电影:电影；构造函数(私有 http:Http){}getMovies(): Promise{返回 this.http.get('http://api.request.com').承诺().then((res:Response)
..
此属性 fromEvent 在类型 'typeof Observable' Angular 6 上不存在
我在尝试创建将 keyup 事件转换为可观察流时遇到问题. 我正在关注 Ng-book 版本 6.我被困在一个示例中，该示例在您键入时搜索 YouTube 视频.当搜索返回时，我们将显示视频缩略图结果列表，以及每个视频的说明和链接. 为此，我们使用 observable.fromEvent:https://github.com/NiLinli/ng-book2-angular-6-r6
..
subscribe 有什么作用，它与 Observable 有什么关系?
我是 Angular 的新手，我遵循的教程有术语“Observable".导师解释了，但我没有完全理解. 什么是Observable，为什么我们总是要调用observable.subscribe()? subscribe() 实际上是做什么的? 解决方案 什么是 Observable? 一个 Observable 可以看作是一个数据源.该数据可能存在(或不存在)并且可能会
..
Rxjs 可观察订阅数
在我的 Angular 2 应用程序中，我有许多可观察对象和订阅.当然，我应该在离开页面时取消订阅，但我想知道是否有可能获得活动订阅的数量.仅用于调试信息或当我忘记退订时. rxjs 里有这些信息吗? 解决方案 可能有点晚了，但你可以利用 rxjs-spy. 此解决方案与提议的解决方案等效，而且在我看来，更易于维护. 我通常在 main.ts 中全局启用它，作为一种即发即
..
如何使用 RxJS Observables 制作倒数计时器?
我正在努力使用 Observables 创建倒数计时器，示例在 http://reactivex.io/documentation/operators/timer.html 似乎不起作用.在这个特定示例中，与 timerInterval 相关的错误不是从计时器返回的 Observable 的函数. 我也一直在尝试其他方法，我想出的最好的方法是: Observable.interval(10
..
如何在不丢失动态更新的情况下组合 3 个 firebase observables
我需要 3 个并行的 Firebase.我需要将它们作为 1 个单一对象加入.代码如下: import {Http} from "@angular/http";从“angularfire2"导入{AngularFireDatabase}；从“../model/thread"导入{Thread}；从“../model/message"导入{Message}；从“../model/participa
..
何时使用 Promise 而不是 observable?
有没有比 observable 更强大的 Promise 的情况?我知道 observables 比 promises 有很多好处.但是有没有什么情况，我应该只使用 observables 上的承诺. 我找到了这个链接，promises vs observables.但这总是向我展示了 observables 比 promises 的好处.我想知道 promise 相对于 observabl
..
使用 Angular 2 中的 Observables 获取数据一次
我有一个服务，它从我的许多 Angular 2 组件中多次使用.它从 Web API 获取客户数据并返回一个 Observable: getCustomers() {返回 this.http.get(this.baseURI + this.url).map((r: 响应) => {让 a = r.json() 作为 Customer[];返回一个；});} 我将此服务注入到我的根组件中，并且在
..
什么触发了 combineLatest?
我有一些可观察的.我需要知道哪个触发了订阅. Observable.combineLatest(this.tournamentsService.getUpcoming(),this.favoriteService.getFavoriteTournaments(),this.teamsService.getTeamRanking(),(锦标赛，最喜欢的，球队)=>{//是什么触发了 combine
..
Angular2 rxjs 按可观察字段排序(可观察)对象列表
我想按可观察字段对事物列表进行排序，但无法围绕可观察对象进行排序以使其正常工作.有人知道如何实现这一目标吗? 最初的情况是这样的: Thing[] things;接口东西{名称:Observable} {{东西名称 |异步}} 因为我显然没有正确描述我的问题:我想对事物列表进行排序的字段是一个 Observa
..
如何从主题中获取最后一个值?
我有两个 Angular2 组件需要通过服务共享数据: @Injectable()导出类 SearchService {private searchResultSource = new Subject()searchResult$ = this.searchResultSource.asObservable()setSearchResults(_searchResult: string):
..
Subject.complete() 是否取消订阅所有听众?
我用这个方法构建了一个简单的确认对话服务(Angular 2): confirm(body?: string, title?: string): Subject{this.confirmation = new Subject();//...在此处显示对话框...“你确定吗?"返回 this.confirmation;}_onYesClicked() {//... 关闭对话框this.confir
..
Angular 6 管道 RxJs 操作符链接 3 个依赖的 observables
我有 3 个依赖的 Rest API 资源(比如 observables)，如下所示: 第一个 observable 将一个项目作为用户数组生成，如下所示: getUsers(): Observable[{“身份证":1，"name": "彼得",“姓氏":“史密斯"},{“身份证":2，"name": "约翰",“姓氏":“韦恩"},...] 2nd observable 可用于获取分
..
使用 Subject.create 创建的主题无法取消订阅
我有一个负责订阅某些 observable 的主题: var timer$ = Rx.Observable.timer(1000, 2000); 当主题像那样链接到主题时 var timerSubject = new Rx.Subject;定时器$.subscribe(timerSubject);var subscription1 = timerSubject.subscribe(n =>
..
使用 Rxjs 或任何东西侦听 Angular 中的数据库数据更改
我在后端(node.js)中有一个服务，我正在通过 angular 订阅它http 客户端服务，它工作正常.对于我的申请，有不止一个用户.所以其他一些用户可以更改数据库数据.所以每当数据库数据发生变化时，我都会立即订阅它们. 这样所有用户都可以查看一致的数据，即与数据库数据同步的数据.我在角度服务中使用 RXJS Observables. 解决方案 在回答之前，请注意满足您的要求说起来容易
..
如何使用 switchMap 取消挂起的 http 请求并只接受最后一次订阅?
我尝试使用 subscription.unsubsribe 取消挂起的 http 请求，如下所示: getAgentList(pageNumber: number, filter: string): any {让 requestUrl: string = 'api/service/agents_search?ACCT='+this.accountId;如果(this.subscription){
..