想要无限期地观察一个随时间变化的数组

Question

我正在尝试使用 Rxjs Observables 来观察我的数组中的变化，但没有运气。

进口：

import {Observable} from 'rxjs/Observable';
import 'rxjs/add/observable/of';

在 Angular 2 的主要服务中

我从 socket.io 服务器获取了一个数组，当用户连接或断开连接时该数组会发生变化。 我在每次更改后设置数据。

我知道当套接字发射时 userList 正在更新，但由于某种原因，我无法弄清楚如何在我的组件中持续观察这种变化。

主要服务：

socket.on('get users',(data)=>{
        this.userList= data;
      });

主服务中的函数 - getUsers()：

  getUsers(){
        return Observable.of(this.userList);
      }

我正在尝试订阅 userList var，并使用异步管道，但都没有更新，它们只在第一次工作然后停止。 如何让它真正无限期地观察变化？

Answer 1

主服务

userList: Subject = new Subject<any>();
userList$ = this.userList.asObservable();

socket.on('get users', (data: any) => {
   this.userList.next(data);
});

在组件中

this.mainService.userList$
.subscribe( 
   (data:any) => console.log(data)
);