我应该取消订阅 Cold Observable 吗?
我知道从 Observable 中取消订阅以防止内存泄漏是一种很好的做法. 但是如果它是Cold Observable，我是否也应该取消订阅它? 例如由 Http.get() 返回的 解决方案 您不需要这样做.HTTP observable 在操作完成后立即调用完成. 来自源代码来源unsubscribe 在错误和完成时被调用. protected _error(err:
..
rxjs相关内容
如何订阅通过@angular/cdk/portal 注入的组件的 Observable?
我正在尝试实现一个基本的(非常基本的)模态实现.我有一个 ModalService 和一个 ModalComponent. ModalService 创建一个 ModalComponent 的实例，并使用@angular/cdk/portal 将其注入到页面中. 我可以让模态显示得很好:-) ModalComponent 有一个 Observable 属性，我希望 ModalSe
..
如何在 React 中使用 RXJS fromEvent?
我正在尝试在反应中记录按钮上的点击事件: const InputBox = () =>{const clicky = fromEvent(document.getElementById('clickMe'),'点击').subscribe(clickety => console.log({ clickety }));返回 (点
..
Angular2 HTTP 使用 observables 订阅显示未定义的数据
我不知道我做错了什么，但不知何故我无法读取数据，尽管数据来自服务器作为响应，甚至数据在我放入时在服务 extractData 方法中显示控制台，但在订阅功能内的组件中，它给了我未定义的信息.帮助我做错了什么，我假设这是异步的问题，但是，我不知道如何正确.任何帮助将是可观的.提前谢谢 Component.ts import { Component, Input, OnInit } from
..
为什么使用 RxJS .asObservable() getter/factory 函数模式?
在使用 RxJS 的许多代码库中，我似乎遇到了通过 getter 或普通 Observables 作为 Observables 公开私有 Subjects 的模式代码>getObservable() 函数.我的问题不是为什么要使用 .asObservable()，而是为什么它看起来如此普遍地包含在 getter/factory 函数中? asObservable() 包裹在 getter/f
..
Typescript/Angular2:将 JSON 转换为与 Observable & 的接口JSONP
我想将我的 json-array 投射到我创建的界面并希望在浏览器中显示它.我认为我的界面可能有问题，但我无法弄清楚...我需要更改什么才能运行我的代码? 界面: 导出接口 Video {身份证号码;名称:字符串；描述:字符串；createdAt:字符串；} app.ts import {JSONP_PROVIDERS, Jsonp} from '@angular/http';从'.
..
Angular2 路由守卫返回 Observable，如何处理错误
我有一个像下面这样的路线守卫 @Injectable()导出类 AuthGuard 实现 CanActivate {构造函数(私有路由器:路由器，私有 authenticationSvc:AuthenticationService){}canActivate(): Observable{返回 this.authenticationSvc.getAuthenticatedUser().map(r＝
..
在 rxjs 可观察链中传递复合数据
我有一个代码块，我在这样的链中调用 observables: getData().flatMap(results => {返回 callNextDataMethod(results);}.flatMap(results2 => {//下一个操作等等}) 现在，我知道 flatMap 将允许我将前一个 observable 的结果传递给下一个.但是，我需要的是既要做到这一点，又要在第一个上传递结
..
RXJS - Angular - 取消订阅主题
如此主题中所述，“官方"在 Angular 5+ 中取消订阅 Observables 的解决方案通常是使用 takeUntil.到现在为止还挺好.我的问题是，如果我订阅的 Observable 实际上是一个主题，这也适用吗? 解决方案 一旦你对任何东西(Subjects 也是)调用 .subscribe() ，需要确保订阅被取消订阅..subscribe()> 处理有限的 Observa
..
使用 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，毫秒){回水管
..
更新 ngrx/store 中的对象
我将 @ngrx/store 用于 Angular 2 应用程序. 我的商店有一个列表，比如 Book 对象.我想更新这些对象之一中的字段.我也碰巧有一个我想要更新的 Book 实例的 Observable(比如，selectedBook). 为了进行更新，我打算使用 UpdateBookAction 和新书的有效负载调用减速器.因此，我通过订阅 selectedBook 然后调用 O
..
angular2 地图数据作为特定对象类型
我基于 Angular2 教程创建了一个非常简单的应用程序. 首先，我有一个非常简单的“书籍"模型: /***书本模型*/出口类图书{公开数据；/*** 构造函数* @param id* @param 标题* @param 页面*/构造函数(公众号，公共标题:字符串，公共页面:数组){警报('它有效')；//只是一个检查}} 在我的服务中，我得到了一本书: 返回 this._http.
..
如何将 Angular2 RC1 与 systemjs 捆绑在一起
在发布候选版本之前，angular 提供了一个捆绑文件.由于发布候选版本没有更多的捆绑文件.包括 angular2 和 rxjs，我的应用程序现在在 7 秒内发出 671 个请求来加载.这阻碍了发展. 有谁知道如何捆绑 angular 和 rxjs 并将它们包含在 system.config 中? 解决方案 为了获得更轻量级的项目，您应该检查 SystemJS Builder 或 J
..
RXJS 控制 observable 调用
我在我的 Angular 2 项目中使用 RxJs 版本 5.我想创建一些 observables 但我不希望立即调用 observables. 在第4版中，您可以使用(例如)Controlled 命令或 可暂停缓冲区.但该功能不是(还没有) 在版本 5 中可用. 我怎样才能在 RxJs 5 中获得这种功能? 我的最终目标是将创建的 observable 排入队列并一一调用它们.
..
“错误"消息:“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
..
根据流中的值暂停 RxJS 流
我有一个简单的组件，带有一个按钮，可以启动和暂停由 RxJS 计时器生成的数字流. import { Component, OnInit } from '@angular/core';import { BehaviorSubject, Observable, timer, merge } from 'rxjs';import { filter, bufferToggle, windowToggl
..
如何在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 可以看作是一个数据源.该数据可能存在(或不存在)并且可能会
..