Rxjs可观察的订阅数
在我的Angular 2应用程序中，我有很多可观察项和订阅项. 当然，离开页面时我应该退订，但我试图找出是否有可能获得活动订阅的数量. 仅用于调试信息或当我忘记退订时. rxjs中是否有可用的此类信息? 解决方案 可能有点晚，但是您可以利用 rxjs-spy . 此解决方案与建议的解决方案等效，并且在我看来，它具有更好的可维护性. 我通常会在main.ts中全局启用它，将
..
rxjs相关内容
RxJS可观察到，从第一次发射开始既发射先前值，又发射当前值
我有一个 BehaviorSubject ，它会定期发出JavaScript对象.我想构造另一个可观察对象，该对象将发出基础可观察对象的先前值和当前值，以便比较两个对象并确定增量. pairwise() 或 bufferCount(2, 1) 运算符正在寻找就像一个很好的拟合，但是它们仅在缓冲区填充后才开始发出，但是我要求此可观察对象从基础可观察对象的第一个事件开始发出. subjec
..
新的Observable(...)和Rx.Observable.create(...)之间的区别?
我正在更新我们的软件，将所有的Promise(以及其他有毛的垃圾)替换为可观察的东西.为了确保遵循最佳做法，我做了一个快速的googlearch并注意到在某些情况下，建议的语法是根据实例的，而在const byInstance = new Observable(_ => { ... }); const byFactory = Rx.Observable.create(_ => { ... });
..
触发值更改为初始化值-angular2
我正在编写一个angular2应用程序，但遇到了麻烦. 首先，我有一个select绑定到formControl: export class MyComponent implements OnInit { profilesBy: Observable; myControl = new FormControl(); constructor(public http:
..
Angular 4计划表单自动保存
我正在尝试在Angular 4中实现表单数据自动保存.它应该像这样工作: 用户以以下形式更改某些数据->调用了一些对DB的保存请求. 假设一些计时器在这里启动了2秒钟. 在先前保存请求的2s期间，所有更改将不会调用任何请求(以减少数据库负载)，但是将触发另一个保存请求，然后2s计时器将到期. 如果目前没有启动计时器，则应立即调用保存请求. 我想RxJS的Observable，Sub
..
错误:类型为typeof Observable的属性计时器不存在
代码在下面 import {Component} from 'angular2/core'; import {Observable} from 'rxjs/Rx'; @Component({ selector: 'my-app', template: 'Ticks (every second) : {{ticks}}' }) export class AppComponent { t
..
如何在订阅Angular 4中返回值
我对角度可观测对象是陌生的.我有一个问题想要在订阅方法内返回一个值.我有 以下方法(getFirebaseData(idForm:string):observable ): getTotalQuestions(idForm:string){ let totalQuestions:number; this.getFirebaseData(idForm+"/Metadatos")
..
创建Observable< T>从结果
我正在尝试Angular2. 我注意到http服务使用Observable对象而不是Promise(我不太喜欢这个选择..async/await即将到来). 在我的服务中，我从Web服务下载了Plants的列表.单击一个工厂，我将使用工艺路线显示详细信息. 但是以这种方式，当我返回时，再次下载了植物(因为再次调用了构造函数). 为避免这种情况，我想做类似的事情: publi
..
Angular2可观察和无极
我开始使用Angular2 Observable，但是找不到与Promises一起使用的.then类似的东西. 这就是我要完成的事情. header.component.ts中的代码 public login() { this._user = AuthService.getInstance().login(this._loginInfo); } 来自auth.serv
..
Angular 4，将可观察到的HTTP响应转换为可观察到的对象
我对可观察对象的概念是新手，需要一些帮助来进行转换. 我有一个从Http请求返回Observable的服务，但我需要将其转换为Observable才能在connect方法内的DataSource上使用它. 反正有这样做吗? 这是我服务中的方法: getPriceTags(): Observable { // Se
..
如何使用BehaviourSubjects在Angular中的组件之间共享来自API调用的数据?
我目前正在构建一个Angular应用程序，在该应用程序中我向api发出请求，并将响应映射到两个不同的数组.我可以在app.components.ts中使用此数据，但是我将根据需要制作新的组件.如何在组件之间共享数据，以确保组件始终具有最新数据，因为我还需要定期调用API. 我在SO和一些youtube视频上都看到了一些答案，但我还没有完全理解它. 我的服务代码是 url = '
..
Angular4 Websocket rxjs重新连接和onError
似乎有几个类似的问题，但是几天后我找不到正确的答案.我的问题是如何知道服务器是否已关闭websocket，以及如何尝试重新连接.我已经看到了几个示例，但是当我想实现在更改视图时从客户端关闭websocket的功能时，它们都无法正常工作. 然后我发现了这个示例，它是到目前为止，我所见过的最好的功能，并且进行了一些小的修改，就能够添加一个效果很好的close函数. 从客户端关闭websoc
..
从Angular 2上的异步管道订阅的BehaviorSubject捕获错误时发生无限循环
我有一个rxjs BehaviorSubject，我使用来自Angular 2的async管道订阅，我有一个catch来处理它引发的最终错误. 问题是，每次遇到错误时，它都会启动一个无限循环，因为我的捕获返回了从BehaviorSubject派生的Observable，并且我认为当我返回catch时async管道将重新订阅到observable. 代码大致如下: ListService
..
ANGULAR 2/4:NgFor中每一行的调用函数
我正在学习AngularJS，我需要一些帮助. 我有一个像这样的模板
..
获取新票证，然后重试第一个请求
更新: 我扩展了Http类，当我deleteDocument()我想要处理错误然后getTicket()时，然后使用新的this.TICKET重试请求deleteDocument(): @Injectable() export class HttpService extends Http { public SERVER_URL: string = 'http://10.0.0.
..
使用Observables通过一个http调用更新几个组件属性
先前的相关帖子: Angular2:减少Http调用次数 上下文仍然相同:我正在尝试设置一个"dico"组件，该组件在输入中需要一个ID和一种语言，并且应该从我的数据库中给我一些翻译的文本. dico.component.ts: @Component({ selector: 'dico', template: `{{text}}` // => The text
..
Angular 2可观察订阅显示未定义
我正面临着与SO Post中的面孔相同的挑战在这里，即使在我的服务中，我也有数据，但在component.ts中的subscription方法中却没有定义. 见下面的代码 p.component.ts private getPayItems():void{ console.log('In getPayItems'); this._payItemService.getPayI
..
包含确认的可观察模式
我正在处理正在记录来自队列的数据.将队列处理成一个Observable很容易，这样我的代码中就可以有多个端点来接收队列中的信息. 此外，我可以确定信息是按顺序到达的.由于Observable可以确保这一点，因此效果也很好. 但是，棘手的一点是，我不希望观察者在完成对前一件事的处理之前就将下一件事通知给观察者.但是观察者完成的处理是异步的. 作为一个更具体的示例，可能很容易理解.想象一下
..
如何使用switchMap取消待处理的http请求并仅接受最后一个订阅?
我尝试使用subscription.unsubsribe这样取消待处理的http请求: getAgentList(pageNumber: number, filter: string): any { let requestUrl: string = 'api/service/agents_search?ACCT=' +this.accountId; if ( this.sub
..
RXJS-Angular-退订主题
如此主题所述，“官方"取消订阅Angular 5+中的Observables的解决方案通常是使用takeUntil.到目前为止，一切都很好.我的问题是，如果我订阅的Observable实际上是一个Subject，这是否也适用? 解决方案 一旦您在任何对象上调用了.subscribe()(主题也是如此)，则需要确保订阅已取消订阅. 处理有限的Observables : 如果您订阅有限的
..