// Это при загрузке страницы:
async function set_data_in_page() {
let value = await localStorage.getItem('value');
document.getElementById("myselect").addEventListener("change", function () {
document.getElementById('street').innerHTML = value;
});
}
// Это чтобы сохранить данные
async function get_data_from_page() {
localStorage.setItem('value', this.value);
}// Подписка со страницы на сервис с сокетами
this.test_data = this.feedService.on("server-response").subscribe(data => { });
// Отписка на этой же странице:
this.test_data.unsubscribe();// Это всё пишем в сервисе!
on(event_name) {
return new Observable<any>(observer => {
this.socket.on(event_name, (data) => {
observer.next(data);
});
});
}
// Это для отправки сообщений
emit(address, message) {
this.socket.emit(address, message)
}// Это всё пишем на странице
ngOnInit() {
this.test_data = this.feedService.on("server-response").subscribe(data => {
console.log('Слушатель работает! ', data)
});
}
ngOnDestroy(){
// При выходе со страницы отписка, сокет больше не работает.
this.test_data.unsubscribe();
}listener = (...args) => {
console.log('req_list: ',args);
}
ngOnInit() {
this.socket.on("test-delete-test-otvet", this.listener);
}
ngOnDestroy(){
this.socket.removeListener("test-delete-test-otvet", this.listener);
}async open_socket(user_id) {
this.socket.connect()
this.socket.emit('new-user', user_id)
this.socket.on('server-response', data => {
// Жду сообщения от сервера
})
}