WebsocketClient on jupyter notebook

websocket_client.py

import sys
import ssl
import time
import json
import threading
import asyncio
import websockets

URL = "wss://localhost/"

ctx = ssl.create_default_context(purpose=ssl.Purpose.CLIENT_AUTH)

class WebSocketClient:
  def __init__(self, loop):
    asyncio.set_event_loop(loop)
    self.loop = loop
   
  async def on_data(self, websocket, req):
    # write processing whenever a new data is arrieved
    pass
  
  async def polling(self, websocket):
    while True:
      req = json.loads(await websocket.recv())
      if req == "":
        await websocket.pong()
      else:
        await self.on_data(websocket, req)
  
  def start(self):
    websocket = self.loop.run_until_complete(
      asyncio.ensure_future(websockets.connect(URL, ssl=ctx))
    )
    self.loop.run_until_complete(self.polling(websocket))
    self.loop.run_forever()

def create():
  c = WebSocketClient(asyncio.new_event_loop())
  c.start()
  
t = threading.Thread(target=create)
try:
  t.setDaemon(True)
  t.start()
  while t.is_alive():
    continue # blocking
except Exception as e:
  print(str(e))
 
t.join()