diff --git a/src/app/services/http/active-user.service.ts b/src/app/services/http/active-user.service.ts index 410ff4c39cce9025126b5c31bdc9ad5e27840e4d..80d7d83fc1ce4fefccd6026dd589a33b5f69b3e0 100644 --- a/src/app/services/http/active-user.service.ts +++ b/src/app/services/http/active-user.service.ts @@ -18,7 +18,7 @@ export class ActiveUserService extends BaseHttpService { super(); } - public getActiveUser(room: Room):Observable<any>{ + public getActiveUser(room: Room): Observable<any>{ const url = '/api/roomsubscription/usercount?ids='+room.id; return this.http.get(url, httpOptions).pipe( tap(_ => ''), @@ -26,14 +26,16 @@ export class ActiveUserService extends BaseHttpService { ); } - public observeUserActivity(room:Room,a:(num:number)=>void):()=>void{ - const interval=setInterval(()=>{ + public observeUserActivity(room: Room,a: (num: number) => void): () => void{ + const f=()=>{ this.getActiveUser(room).subscribe(e=>{ if(e&&e.length>0){ a(e[0]); } - }) - },5000); + }); + }; + f(); + const interval=setInterval(()=>f(),5000); return ()=>clearInterval(interval); }