Angular 5 组件在 Observable 返回时不更新

Question

我正在使用 Angular 5 和 SignalR 构建应用程序。我创建了一个管理集线器的服务，当有事件从服务器传入时，它会将值放入 BehaviorSubject 私有变量中。有一个只读属性应该放出我可以从组件订阅的 observable。

在组件中，我已经订阅了服务的Observable，但是在属性更新时它仍然没有更新。

我知道“测试”属性正在更新，因为我必须告诉我我收到了来自服务器的配置的警报。

有人能指出我可能遗漏了什么或不完全了解 Angular 如何处理更改检测或我可能如何破坏它吗？

服务：

import { Injectable, Input, Output, EventEmitter, NgZone } from '@angular/core';
import { Http, Response } from '@angular/http';
import 'rxjs/add/operator/map';
import {BehaviorSubject} from 'rxjs/BehaviorSubject';
import { APIModels } from './../../shared/APIModels';
import {Observable} from "rxjs/Observable";

declare var $;
@Injectable()
export class DisplayViewerConfigurationService {
    private _displayConfiguration: BehaviorSubject<APIModels.ClientConfigurationModel>;
    public readonly displayConfiguraiton: Observable<APIModels.ClientConfigurationModel>;
    public hubProxy;
    @Input() displayID;

    constructor(public http: Http) {
        var test = new APIModels.ClientConfigurationModel();
        test.Display = new APIModels.DisplayConfig();
        test.Display.DisplayID = "testID";
        this._displayConfiguration = new BehaviorSubject(test);
        this.displayConfiguraiton = this._displayConfiguration.asObservable();
    }

    public startConnection(): void {
        var hubConnection = $.hubConnection("http://localhost:49890", {useDefaultCredentials: true});
        this.hubProxy = hubConnection.createHubProxy('testHub');
        hubConnection.qs = "displayid=" + this.displayID;
        this.hubProxy.on('receiveConfig', (e: any) => {
            this._displayConfiguration.next(e);
            alert("now" + JSON.stringify(e));
        });
        
        hubConnection.start();
    }
}

组件 TS：

import { Component, OnInit, Output, Input, ChangeDetectorRef } from '@angular/core';
import { DisplayViewerConfigurationService } from './../../services/displayviewerconfiguration-service/displayviewerconfiguration-service';
import 'rxjs/symbol/observable';
import { Observable } from 'rxjs/observable';
import { APIModels } from './../../shared/APIModels';
import { Helpers } from './../../shared/Helpers';

@Component({
  selector: 'app-displayiframe',
  templateUrl: './display-iframe.component.html',
  
})

export class DisplayScreenComponent implements OnInit {
  
    constructor(public viewer: DisplayViewerConfigurationService) {
        this.viewer.displayID = "278307b8-da34-4569-8b93-d5212b9e0e0d";
        this.viewer.startConnection();
        this.ObjCopy = new Helpers.ObjectCopyHelpers();
      
    }

    ngOnInit() {
        this.viewer.displayConfiguraiton.subscribe(data => {this.test = data; alert(JSON.stringify(this.test);});
    }

    @Input() test: any;
    public stackHeight: string;
    public ObjCopy: Helpers.ObjectCopyHelpers;
   
}

组件模板：

<div>
   {{test.Display.DisplayID}}
</div>

我也尝试过直接订阅可观察对象。还是没用。

<div>
   {{viewer.displayConfiguraiton.Display.DisplayID | async}}
</div>

编辑：

包括此堆栈的模块和父组件以帮助提供进一步说明。

模块：

import { NgModule } from '@angular/core';
import { CommonModule } from '@angular/common';
import { DisplayViewerConfigurationService } from './../services/displayviewerconfiguration-service/displayviewerconfiguration-service';
import { DisplayViewerComponent } from './display-viewer.component';
import { DisplayScreenComponent } from './display-iframe/display-iframe.component';
import { HttpModule } from '@angular/http';
import { APIModels } from "./../shared/APIModels";
import { Helpers } from "./../shared/Helpers";

@NgModule({
  imports: [
    CommonModule
    HttpModule,
  ],
  declarations: [DisplayViewerComponent, DisplayScreenComponent],
  
  entryComponents: [DisplayViewerComponent, DisplayScreenComponent],
  
  providers: [DisplayViewerConfigurationService],
  exports: [DisplayViewerComponent],
})
export class DisplayViewerModule { }

父组件：

import { Component, OnInit } from '@angular/core';
import { NouisliderModule, NouisliderComponent } from 'ng2-nouislider/src/nouislider';
import { DisplayViewerConfigurationService } from './../services/displayviewerconfiguration-service/displayviewerconfiguration-service';
import { DisplayScreenComponent } from './display-iframe/display-iframe.component';
import 'rxjs/symbol/observable';
import { Observable } from 'rxjs/observable';

@Component({
  selector: 'app-displayviewer',
  templateUrl: './display-viewer.component.html'
  
})

export class DisplayViewerComponent implements OnInit {
  constructor() {
}

  ngOnInit() {

  }

}

父组件模板：

<app-displayiframe></app-displayiframe>

编辑：

我一直在做一些研究，并决定尝试一下这个例子：使用 Web 套接字将实时数据推送到 Angular 服务。

执行此操作后，相同的行为仍然存在，没有触发更改检测。

在进行更多研究并找到此页面后：Angular 2 - View not updated after model changes。

我决定ChangeDetectorRef.detectChanges();在更新组件的属性后尝试运行。这样做实际上解决了我的问题并导致组件按照我的预期进行更新。

例子：

this.viewer.startConnection()
    .subscribe(config => {
        this.test.push(config);
        alert(JSON.stringify(this.test));
        this.changeDetector.detectChanges();
        alert(NgZone.isInAngularZone());
    });

我还添加了一个警报，告诉我我正在运行的代码是否在 AngularZone 内。事实证明，我返回的 observable 似乎不在 Angular Zone 内。难怪我在更改属性时没有得到任何更改检测。

为什么以这种方式创建 observable 会导致订阅在 AngularZone 之外？有没有一种方法可以解决这个问题，使其在区域范围内，而不必依赖手动强制应用程序检测更改？

Answer 1

所以，事实证明我正在使用一个不在 NgZone 中的库。我能够通过使用 NgZone.isInAngularZone() 来确定调用是否在区域内；并在订阅回调中放置警报。一旦我发现我超出了该区域，我发现我可以将 ChangeDetectorRef 注入组件并在订阅中放置一个手动更改检测调用。示例：this.changeDetector.detectChanges();

这只是解决根本问题的创可贴。经过更多的研究，我找到了这篇文章。这指出您可以强制在区域内运行调用。所以我用这个替换了集线器代理回调。

this.hubProxy.on('receiveConfig', (e: any) => {
    this.ngZone.run(() => this.observer.next(e));
});

这迫使 observable 在 NgZone 中运行，允许默认更改检测树检测更改。