Source code for ws4py.client.threadedclient
# -*- coding: utf-8 -*-
import threading
from ws4py.client import WebSocketBaseClient
__all__ = ['WebSocketClient']
[docs]class WebSocketClient(WebSocketBaseClient):
def __init__(self, url, protocols=None, extensions=None):
WebSocketBaseClient.__init__(self, url, protocols, extensions)
self._th = threading.Thread(target=self.run, name='WebSocketClient')
self._th.daemon = True
@property
def daemon(self):
return self._th.daemon
@daemon.setter
[docs] def daemon(self, flag):
self._th.daemon = flag
[docs] def handshake_ok(self):
self._th.start()
self._th.join(timeout=1.0)