Update 0.4.0 (#10)

- Fixed an error that occurs when a track segment is smaller than the
required size

Author: peachboy0

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "seaplayer-audio"
-version = "0.3.10"
+version = "0.4.0"
 description = "A library for async/sync playback audio."
 repository = "https://github.com/romanin-rf/seaplayer-audio"
 authors = ["Romanin <60302782+romanin-rf@users.noreply.github.com>"]

seaplayer_audio/streamers/callbackstreamersnd.py

@@ -39,8 +39,11 @@ def __callback__(self, outdata: ndarray, frames: int, time, status):
                 d = self.queue.get_nowait()
             except:
                 return
-            wdata = d[:frames]
-            self.buffer = d[frames:]
+            if len(d) >= frames:
+                wdata = d[:frames]
+                self.buffer = d[frames:]
+            else:
+                wdata = npvstack([d, npzeros((frames - len(d), self.channels), dtype=outdata.dtype)])
         elif len(self.buffer) >= frames:
             wdata = self.buffer[:frames]
             self.buffer = self.buffer[frames:]
@@ -54,6 +57,8 @@ def __callback__(self, outdata: ndarray, frames: int, time, status):
             needed = frames - len(wdata)
             wdata = npvstack([wdata, d[:needed]])
             self.buffer = d[needed:]
+            if len(wdata) < frames:
+                wdata = npvstack([wdata, npzeros((frames - len(wdata), self.channels), dtype=outdata.dtype)])
         elif (len(self.buffer) < frames) and self.queue.empty():
             wdata = self.buffer.copy()
             self.buffer = None
@@ -130,8 +135,11 @@ def __callback__(self, outdata: ndarray, frames: int, time, status):
                 d = asyncio.run_coroutine_threadsafe(self.queue.get_nowait(), self.loop).result()
             except:
                 return
-            wdata = d[:frames]
-            self.buffer = d[frames:]
+            if len(d) >= frames:
+                wdata = d[:frames]
+                self.buffer = d[frames:]
+            else:
+                wdata = npvstack([d, npzeros((frames - len(d), self.channels), dtype=outdata.dtype)])
         elif len(self.buffer) >= frames:
             wdata = self.buffer[:frames]
             self.buffer = self.buffer[frames:]
@@ -145,6 +153,8 @@ def __callback__(self, outdata: ndarray, frames: int, time, status):
             needed = frames - len(wdata)
             wdata = npvstack([wdata, d[:needed]])
             self.buffer = d[needed:]
+            if len(wdata) < frames:
+                wdata = npvstack([wdata, npzeros((frames - len(wdata), self.channels), dtype=outdata.dtype)])
         elif (len(self.buffer) < frames) and self.queue.empty():
             wdata = self.buffer.copy()
             self.buffer = None