Rxjs Subject.asObservable() 不工作但 BehaviorSubject 工作......为什么？

Question

我已经检查了这个https://github.com/angular/angular/issues/12129 但我没有看到任何解决方案......

Angular 2.0.1 AsyncPipe 不适用于 Rx Subject。

这里的解决方法是在组件中创建一个可观察的变量

我有但仍然没有工作......不知道为什么它不起作用，如果我将我的主题切换UserStateService到 BehaviorSubject 一切正常......

注意：UserDataService 和 UsersStateService 都在根 app.module.ts 中提供。

user-data.service.ts -> 发出我在组件中调用的 http 请求

fetchUsers():void{
   this.httpClient.get<User[]>(this.apiUrl, {
  observe: 'body',
  responseType: 'json'
})
.subscribe( (response: User[])=>{
    this.usersStateService.setUsersList(response);  <-- set to local state service

  });

}

用户状态.service.ts

userListState = new Subject<User[]>();   <-- Change this to BehaviorSubject<User[]>([])  everything works!

setUsersList(users: User[]):void {
  this.userListState.next(users.slice());
}

getUsersListState():Observable<User[]>{
   return this.userListState.asObservable();
}

组件.ts

 users: Observable<User[]>;

 ngOnInit() {

 if(this.usersStateService.hasUserList()){

  this.users = this.usersStateService.getUsersListState();  -|
                                                             |
  // this.usersStateService.getUsersListState()              |
  //   .subscribe((x) => console.log(x));                   -| <-- This does not output for some reason IF Subject... BehaviorSubject works..
}else{
  console.log("No data in local stat -> fetch") . <-- This works either with Subject or BehaviorSubject
  this.userData.fetchUsers();
  this.users = this.usersStateService.getUsersListState();
}

}

HTML

<li *ngFor="let u of (users | async)">u.name</li>

请任何见解将是伟大的谢谢！

Answer 1

主题不持有任何数据，它只是调用任何订阅它的值。BehaviorSubject 保存数据，每次您调用发射时，它都会替换当前数据。

当您尝试从您的服务控制台日志时， UserList:
With Subject它不包含任何持久数据。

this.usersStateService.getUsersListState()              
 .subscribe((x) => console.log(x));  ==> would be empty 

使用 BehaviorSubject，它保存最后的数据，也可以用值进行初始化。

let _array = ['one','two']
let bs = new BehaviorSubject<any>(_array ).asObservable();
bs.subscribe(arr => {
 console.log(arr) // ==> Would log the _array: ['one','two']
})

因此，在您的情况下，当您尝试通过 Subject 获取数据时，它在第一次调用后（发出时）不存在，而 BehaviorSubject 保存您的初始值，并且每次发出时，总是存在持久数据。
**如果您每次需要多个值，您应该查看 ReplySubject