AK
Size: a a a
AK
AK
SФ
if(this.check())
O
O
AK
AK
SФ
private _status: boolean
connection() {
this.check().subscribe(status=>{...})
}
check() {
return this.http.get();
}
O
SФ
SФ
.subscribe()
AK
AK
O
AK
AK
AK
AK
O
connect() {
this.checkWsStatus().subscribe(result => {
this.websocket_status = result.status
if (this.websocket_status) {
this.websocket = new WebSocket(this.websocket_url)
const source = new Observable(observer => this.websocket.addEventListener('message', event => observer.next(event.data)))
this.websocket.onopen = () =>
console.log('Opened')
this.websocket.onclose = (close) =>
console.log(`WebSocket connection is closed`)
return source
}
})
}
checkWsStatus() {
return this.http.get(this.websocket_status_url)
}