onyx_online/vban-cmd-python
1
0
Fork 0
mirror of https://github.com/onyx-and-iris/vban-cmd-python.git synced 2025-04-18 11:13:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

Compare commits

base: onyx_online:cbcca144813661a00178611222ec7cbf263592fe
Branches Tags
onyx_online:dev
onyx_online:add-event-stop-object
onyx_online:main
..
compare: onyx_online:72d182a48861db7f57601d5b55fe5d7ac317d549
Branches Tags
onyx_online:dev
onyx_online:add-event-stop-object
onyx_online:main

No commits in common. "cbcca144813661a00178611222ec7cbf263592fe" and "72d182a48861db7f57601d5b55fe5d7ac317d549" have entirely different histories.
cbcca14481 ... 72d182a488

2 changed files with 3 additions and 3 deletions
Show Stats Expand all files Collapse all files

2
pyproject.toml
View File

@ -1,6 +1,6 @@
[tool.poetry] [tool.poetry]
name = "vban-cmd" name = "vban-cmd"
version = "2.4.3" version = "2.4.2"
description = "Python interface for the VBAN RT Packet Service (Sendtext)" description = "Python interface for the VBAN RT Packet Service (Sendtext)"
authors = ["onyx-and-iris <code@onyxandiris.online>"] authors = ["onyx-and-iris <code@onyxandiris.online>"]
license = "MIT" license = "MIT"

4
vban_cmd/worker.py
View File

@ -31,7 +31,7 @@ class Subscriber(threading.Thread):
self.packet.framecounter = ( self.packet.framecounter = (
int.from_bytes(self.packet.framecounter, "little") + 1 int.from_bytes(self.packet.framecounter, "little") + 1
).to_bytes(4, "little") ).to_bytes(4, "little")
self.wait_until_stopped(10) self.until_stopped(10)
except socket.gaierror as e: except socket.gaierror as e:
self.logger.exception(f"{type(e).__name__}: {e}") self.logger.exception(f"{type(e).__name__}: {e}")
raise VBANCMDConnectionError( raise VBANCMDConnectionError(
@ -42,7 +42,7 @@ class Subscriber(threading.Thread):
def stopped(self): def stopped(self):
return self.stop_event.is_set() return self.stop_event.is_set()
def wait_until_stopped(self, timeout, period=0.2): def until_stopped(self, timeout, period=0.2):
must_end = time.time() + timeout must_end = time.time() + timeout
while time.time() < must_end: while time.time() < must_end:
if self.stopped(): if self.stopped():