Вы можете обернуть websocket из библиотеки rxjs.
Импортировать его так:
import {webSocket, WebSocketSubject} from 'rxjs/webSocket';
А затем создать такой как:
private webSocket: WebSocketSubject = webSocket(environment.chatUrl);
ЗатемВы можете подписаться на него, чтобы получать входящие сообщения:
this.subscription = this.webSocket.subscribe(
msg => {
// do something with the message
},
err => {
// handle the error
console.log('error!', err);
},
() => {
// handle getting disconnected
console.log('websocket closed');
}
);
И отправлять сообщение:
this.webSocket.next(message);
И не забудьте отписаться от веб-сокета, когда закончите.