We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 45ca49f commit da168c0Copy full SHA for da168c0
1 file changed
common/src/main/kotlin/com/lambda/util/collections/LimitedDecayQueue.kt
@@ -42,7 +42,17 @@ class LimitedDecayQueue<E>(
42
43
override fun iterator(): MutableIterator<E> {
44
cleanUp()
45
- return queue.map { it.first }.iterator() as MutableIterator<E>
+ return object : MutableIterator<E> {
46
+ private val delegate = queue.iterator()
47
+
48
+ override fun hasNext(): Boolean = delegate.hasNext()
49
50
+ override fun next(): E = delegate.next().first
51
52
+ override fun remove() {
53
+ delegate.remove() // This affects the underlying queue directly
54
+ }
55
56
}
57
58
@Synchronized
0 commit comments