Fix prebuffer storage length (#252)

* Fix prebuffer storage length #160 * up version Co-authored-by: Grigory Gorshkov <[email protected]>
ch1ller0 · Apr 13, 2021 · 50472b7 · 50472b7
1 parent 1112ceb
commit 50472b7
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@fridgefm/radio-core",
   "author": "Grigory Gorshkov",
-  "version": "3.0.1",
+  "version": "3.0.2",
   "description": "internet radio engine made on NodeJS platform",
   "license": "MIT",
   "main": "./lib/index.js",

diff --git a/src/features/Prebuffer.ts b/src/features/Prebuffer.ts
@@ -17,7 +17,7 @@ export class Prebuffer {
 
   public modify(chunks: Buffer[]) {
     chunks.forEach((ch) => {
-      if (this._storage.length > this._prebufferLength) {
+      if (this._storage.length >= this._prebufferLength) {
         this._storage.shift();
       }
 

diff --git a/src/features/__tests__/Prebuffer.test.ts b/src/features/__tests__/Prebuffer.test.ts
@@ -23,10 +23,10 @@ describe('features/Prebuffer', () => {
 
     // overflow - the length stays the same
     instance.modify(createChunks('1234'));
-    expect(instance.getStorage().join('')).toEqual('4567890123');
+    expect(instance.getStorage().join('')).toEqual('5678901234');
 
     instance.modify(createChunks('1234'));
-    expect(instance.getStorage().join('')).toEqual('8901234123');
+    expect(instance.getStorage().join('')).toEqual('9012341234');
   });
 
   it('uses default if length not set', () => {