RxJS Observable 不会触发 Angular Material 的变化

Question

我正在尝试在我创建的服务连接到他的服务器后立即执行一项操作。目前我只是保存一个connected: boolean，它会改变连接和连接丢失的状态，并将其作为可观察对象返回。

通过订阅，我只能检索 observable 的初始状态。当布尔值更改其值（它确实如此）时，订阅不会不触发。

感谢任何帮助。

app.component.ts（订阅）

ngOnInit() {
    this.moduleService.isConnected().subscribe(value => console.log(value)); 
  }

module.service.ts（在组件中注入）

isConnected(): Observable<boolean> {
    return of(this._mqttApi.isConnected());
  }

mqttApi.ts（此处为布尔值更改）

connected: boolean = false;

onConnect(){
  connected = true;
}

onConnectionLost(){
  connected = false
}

public isConnected(): boolean{
  return this.connected;
}

Answer 1

在您的 module.service.ts 中，您只返回一个使用 of 只发出一次的可观察对象。您需要的是 BehaviorSubject 或 Subject 作为连接属性的类型，而不是 mqttApi.ts 中的布尔值

然后，如果您不希望服务使用此 observable 更改主题，请使用 connected.asObservable() 将该 observable 公开。否则，您也可以公开主题/行为主题。

在你的方法里面你调用connected.next(true|false)

类似这样的：

connected: BehaviorSubject<boolean> = new BehaviorSubject(false);

onConnect(){
  this.connected.next(true);
}

onConnectionLost(){
  this.connected.next(false)
}

public isConnected(): Observable<boolean>{
  return this.connected.asObservable();
}