Веб-сокет RxJs не может получить ответ от веб-скокета

Question

Я использую веб-сокет RxJ для подключения к серверу веб-сокетов. Как только соединение установлено, я должен вызвать функцию из пользовательского интерфейса, которая передаст некоторую строку в websocket, и сервер должен отправить ответ на основе переданной строки. Я использовал следующую реализацию:

socket = webSocket('ws://172.25.118.25:8083/socket');
ngOnInit() {
  this.socket.subscribe();
 }
  showVal(val) {
    this.socket.subscribe(
      (msg) => {console.log('message received: ' + msg)},
      () => console.log('complete')
    );
  this.socket.next(val);
}

Теперь, когда функция вызывается, я вижу, что запрос отправляется на сервер, и сервер также обрабатывает его, но только

() => console.log ('complete')

эта часть исполняется.