WebSocket с угловой 6 разрушается

Question

Я пытаюсь научиться использовать WebSocket с бэкэндом Python и интерфейсом Angular 6.
Похоже, что соединение WebSocket разрушается, так как обновления работают только тогда, когда я ставлю точку останова в следующей строке:

ngOnInit() {
   this.sub = this.socketService.getQuotes()
  .subscribe(quote => {
    console.log('got price: ' + quote);
    this.price = quote;
  });
} // breakpoint

Бэкэнд довольно прост:

def send_market_price():
    threading.Timer(5.0, send_market_price).start()
    print('sending price ws')
    socketio.emit('market', market.update_market())

if __name__ == '__main__':
    send_market_price()
    print('starting')
    socketio.run(app)

услуга тоже базовая:

@Injectable()
export class SocketService {
  public socket;
  public observer: Observer<number>;

  getQuotes(): Observable<number> {
    this.socket = socketio(SERVER_URL);

    this.socket.on('market', (res) => {
      this.observer.next(res);
    });

    return this.createObservable();
  }

 createObservable(): Observable<number> {
   return new Observable(observer => {
   this.observer = observer;
 });
}

Что-то не так в моем коде, чтобы сделать эту основную функцию?

РЕДАКТИРОВАТЬ

после некоторых тестов, похоже, что бэкэнд прослушивается. Я сделал то же самое, получив код Node.js, и он прекрасно работает.

Что не так с этим кодом Python:

import threading
from flask import Flask, jsonify
from flask_cors import CORS
from flask_socketio import SocketIO

from market_engine import market
from market_engine.market import RandomMarket

app = Flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app)
CORS(app)
market = RandomMarket()

@socketio.on('connect')
def connect():
    print('Client connected')

@socketio.on('disconnect')
def disconnect():
    print('Client disconnected')

def send_market_price():
    threading.Timer(5.0, send_market_price).start()
    print('sending price ws')
    socketio.emit('market', market.update_market())

if __name__ == '__main__':
    send_market_price()
    print('starting')
    socketio.run(app)