Account for possible null heap in TimerHeap#steal

armanbilge · Feb 19, 2024 · 0927d34 · 0927d34
1 parent 02f1c9d
commit 0927d34
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/core/jvm/src/main/scala/cats/effect/unsafe/TimerHeap.scala b/core/jvm/src/main/scala/cats/effect/unsafe/TimerHeap.scala
@@ -164,8 +164,10 @@ private final class TimerHeap extends AtomicInteger {
       } else false
 
     val heap = this.heap // local copy
-    val size = Math.min(this.size, heap.length - 1)
-    go(heap, size, 1)
+    if (heap ne null) {
+      val size = Math.min(this.size, heap.length - 1)
+      go(heap, size, 1)
+    } else false
   }
 
   /**