diff options
| author | liris <liris.pp@gmail.com> | 2019-12-25 21:07:19 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-12-25 21:07:19 +0900 |
| commit | 647820961d44f56591d5e5a1c42888150a57bf48 (patch) | |
| tree | 73060943138f74dfd1480dc64df6ce39a5cebb58 /websocket | |
| parent | 14f6c9326dc907bea3cfdcf3e45f620200a2ae16 (diff) | |
| parent | aae7d973fff3bbb47f47253d2a68c982d2468a3d (diff) | |
| download | websocket-client-647820961d44f56591d5e5a1c42888150a57bf48.tar.gz | |
Merge pull request #586 from olie304/patch-1
Fix for errors that occur when closing websocket from another thread
Diffstat (limited to 'websocket')
| -rw-r--r-- | websocket/_app.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/websocket/_app.py b/websocket/_app.py index 81aa1fc..cd88b94 100644 --- a/websocket/_app.py +++ b/websocket/_app.py @@ -46,7 +46,7 @@ class Dispatcher: self.ping_timeout = ping_timeout def read(self, sock, read_callback, check_callback): - while self.app.sock.connected: + while self.app.keep_running: r, w, e = select.select( (self.app.sock.sock, ), (), (), self.ping_timeout) if r: @@ -60,7 +60,7 @@ class SSLDispacther: self.ping_timeout = ping_timeout def read(self, sock, read_callback, check_callback): - while self.app.sock.connected: + while self.app.keep_running: r = self.select() if r: if not read_callback(): |