Fixed decay queue set max size

Author: emyfops

common/src/main/kotlin/com/lambda/util/collections/LimitedDecayQueue.kt

@@ -106,11 +106,17 @@ class LimitedDecayQueue<E>(
      * Updates the maximum allowed size for the queue and triggers a cleanup operation
      * to remove elements exceeding the new size or falling outside the allowed time interval.
      *
+     * Elements starting from the head will be removed.
+     *
      * @param newSize The new maximum size for the queue. Must be a non-negative integer.
      */
     fun setMaxSize(newSize: Int) {
         sizeLimit = newSize
         cleanUp()
+
+        while (queue.size > newSize) {
+            queue.poll()
+        }
     }
 
     /**
@@ -131,4 +137,4 @@ class LimitedDecayQueue<E>(
             onDecay(queue.poll().first)
         }
     }
-}
+}

common/src/test/kotlin/LimitedDecayQueueTest.kt

@@ -137,11 +137,7 @@ class LimitedDecayQueueTest {
 
         queue.setMaxSize(2) // Reduce size limit to 2
 
-        queue.add("Element4")
-
-        // Verify that the queue is limited to 2 elements, and oldest element is removed
         assertEquals(2, queue.size)
-        assertTrue(onDecayCalled.contains("Element1")) // "Element1" should be decayed
     }
 
     @Test