Fixed bug in _obtain from typo
This commit is contained in:
parent
b0e85842e3
commit
4961e119b3
|
@ -84,7 +84,7 @@ class SocketClient(Thread):
|
|||
|
||||
def _queue_thread(self, inbox, timeout):
|
||||
while not self.kill_switch.is_set():
|
||||
for message in self._obtain(inbox, timeout):
|
||||
for message in self._obtain("inbox", timeout):
|
||||
if self.broken.is_set():
|
||||
self.reconnecting.wait()
|
||||
self.send_message(message)
|
||||
|
@ -151,7 +151,7 @@ class SocketClient(Thread):
|
|||
|
||||
def send(self, message):
|
||||
self._inbox.put(message)
|
||||
cast(self._bridge, "send" ("inbox", message))
|
||||
cast(self._bridge, "send", ("inbox", message))
|
||||
|
||||
def connect(self, bridge):
|
||||
self._bridge = bridge()
|
||||
|
|
Loading…
Reference in New Issue