fix(core): update

This commit is contained in:
Philipp Kunz 2019-11-08 17:31:04 +01:00
parent 765bc73197
commit 5e64f4ca25

View File

@ -33,7 +33,7 @@ export class SmartsocketClient {
public serverPort: number;
public autoReconnect: boolean;
public eventSubject = new plugins.smartrx.rxjs.Subject();
public eventSubject = new plugins.smartrx.rxjs.Subject<interfaces.TConnectionEvent>();
public socketFunctions = new plugins.lik.Objectmap<SocketFunction<any>>();
public socketRequests = new plugins.lik.Objectmap<SocketRequest<any>>();
@ -135,6 +135,7 @@ export class SmartsocketClient {
}
defaultLogger.log('warn', `disconnected from server ${this.remoteShortId}`);
this.remoteShortId = null;
this.eventSubject.next('terminated');
if (this.autoReconnect) {
this.tryDebouncedReconnect();