create ws on connect
This commit is contained in:
parent
4d4dd841b1
commit
4c6fed4b10
1 changed files with 3 additions and 3 deletions
|
|
@ -43,8 +43,10 @@ class Relay:
|
||||||
self.proxy: dict = {}
|
self.proxy: dict = {}
|
||||||
self.lock = Lock()
|
self.lock = Lock()
|
||||||
self.queue = Queue()
|
self.queue = Queue()
|
||||||
|
|
||||||
|
def connect(self, ssl_options: dict = None, proxy: dict = None):
|
||||||
self.ws = WebSocketApp(
|
self.ws = WebSocketApp(
|
||||||
url,
|
self.url,
|
||||||
on_open=self._on_open,
|
on_open=self._on_open,
|
||||||
on_message=self._on_message,
|
on_message=self._on_message,
|
||||||
on_error=self._on_error,
|
on_error=self._on_error,
|
||||||
|
|
@ -52,8 +54,6 @@ class Relay:
|
||||||
on_ping=self._on_ping,
|
on_ping=self._on_ping,
|
||||||
on_pong=self._on_pong,
|
on_pong=self._on_pong,
|
||||||
)
|
)
|
||||||
|
|
||||||
def connect(self, ssl_options: dict = None, proxy: dict = None):
|
|
||||||
self.ssl_options = ssl_options
|
self.ssl_options = ssl_options
|
||||||
self.proxy = proxy
|
self.proxy = proxy
|
||||||
if not self.connected:
|
if not self.connected:
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue