Doing UserJoin on connect / reconnect.

This commit is contained in:
Dessalines 2020-02-02 16:37:57 -05:00
parent 3ddbe2e370
commit ad8e47f8d2

View file

@ -61,6 +61,9 @@ export class WebSocketService {
this.ws = new ReconnectingWebSocket(wsUri);
this.ws.onopen = () => {
console.log(`Connected to ${wsUri}`);
if (UserService.Instance.user) {
this.userJoin();
}
};
this.subject = Observable.create((obs: any) => {
@ -68,10 +71,6 @@ export class WebSocketService {
obs.next(JSON.parse(e.data));
};
}).pipe(share());
if (UserService.Instance.user) {
this.userJoin();
}
}
public static get Instance() {