From 8cfeb45fcbdd47759a4600b9a6fe4ab38cb1f73a Mon Sep 17 00:00:00 2001
From: onyx-and-iris <code@onyxandiris.online>
Date: Sun, 1 Mar 2026 11:09:28 +0000
Subject: [PATCH] update imports

---
 vban_cmd/worker.py | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/vban_cmd/worker.py b/vban_cmd/worker.py
index 7c176d9..9bb6713 100644
--- a/vban_cmd/worker.py
+++ b/vban_cmd/worker.py
@@ -5,16 +5,16 @@ import time
 
 from .enums import NBS
 from .error import VBANCMDConnectionError
-from .packet import (
+from .packet.headers import (
     HEADER_SIZE,
     VBAN_PROTOCOL_SERVICE,
     VBAN_SERVICE_RTPACKET,
-    SubscribeHeader,
     VbanPacket,
-    VbanPacketNBS0,
-    VbanPacketNBS1,
-    VbanRtPacketHeader,
+    VbanResponseHeader,
+    VbanSubscribeHeader,
 )
+from .packet.nbs0 import VbanPacketNBS0
+from .packet.nbs1 import VbanPacketNBS1
 from .util import bump_framecounter
 
 logger = logging.getLogger(__name__)
@@ -34,7 +34,7 @@ class Subscriber(threading.Thread):
         while not self.stopped():
             try:
                 for nbs in NBS:
-                    sub_packet = SubscribeHeader().to_bytes(nbs, self._framecounter)
+                    sub_packet = VbanSubscribeHeader().to_bytes(nbs, self._framecounter)
                     self._remote.sock.sendto(
                         sub_packet, (self._remote.ip, self._remote.port)
                     )
@@ -90,7 +90,7 @@ class Producer(threading.Thread):
             if len(data) < HEADER_SIZE:
                 return
 
-            response_header = VbanRtPacketHeader.from_bytes(data[:HEADER_SIZE])
+            response_header = VbanResponseHeader.from_bytes(data[:HEADER_SIZE])
             if (
                 response_header.format_sr != VBAN_PROTOCOL_SERVICE
                 or response_header.format_nbc != VBAN_SERVICE_RTPACKET