Почему-то было тяжело выстроить диалог, ты уклонялся от ответов. У нас внутри %companyname% много коммуникаций, проработка проекта лежит на разработчике. Мы понимаем, что тебе будет тяжеловато встроится в процесс разработки наш.
ws = new Websocket("localhost/app");
emitter = new EventEmitter();
ws.onmessage = event => {
if (event.data .... == 'success') {
emitter.emit('blablalbla');
} else {
emitter.error('blablalbla');
}
};
private timeoutError(observer) {
setTimeout(() => {
observer.error();
}, 5000);
}
public login(login: string, password): Observable<any> {
ws.send(login, password);
return new Observable(observer => {
this.emitter.subscribe(() => {
observer.next();
observer.complete();
},
() => observer.error()
);
this.timeoutError(observer)
});
}