fix: priority queue delay logic was inverse

collections/priorityqueue.go

@@ -271,10 +271,8 @@ func (queue *Queue[T]) Dequeue() (T, bool) {
 
 	// Peek for notBefore
 	v, _ := queue.heap.Peek()
-	if !v.notBefore.IsZero() {
-		if time.Until(v.notBefore) < 0 {
-			return zero, false
-		}
+	if !v.notBefore.IsZero() && time.Until(v.notBefore) > 0 {
+		return zero, false
 	}
 
 	wrapper, ok := queue.heap.Pop()

collections/priorityqueue_test.go

@@ -223,21 +223,35 @@ func TestPriorityQueueWithDelay(t *testing.T) {
 	g.Expect(err).To(BeNil())
 	g.Expect(pq.Size()).To(BeNumerically("==", 0))
 
-	pq.EnqueueWithDelay("item1-delay-10s", 10*time.Second)
-	pq.EnqueueWithDelay("item1-delay-05s", 5*time.Second)
+	pq.EnqueueWithDelay("item1-delay-06s", 6*time.Second)
+	pq.EnqueueWithDelay("item1-delay-03s", 3*time.Second)
 	pq.Enqueue("item1")
 
+	start := time.Now()
+
 	var items []string
 	for {
 		if pq.Size() == 0 {
 			break
 		}
 
-		item, _ := pq.Dequeue()
-		items = append(items, item)
+		item, valid := pq.Dequeue()
+		if valid {
+			items = append(items, item)
+		}
+
+		if time.Now().Sub(start) > (2*time.Second) && time.Now().Sub(start) < (3*time.Second) {
+			g.Expect(items).To(Equal([]string{"item1"}))
+		}
+		if time.Now().Sub(start) > (3*time.Second) && time.Now().Sub(start) < (5*time.Second) {
+			g.Expect(items).To(Equal([]string{"item1", "item1-delay-03s"}))
+		}
+		if time.Now().Sub(start) > (6 * time.Second) {
+			g.Expect(items).To(Equal([]string{"item1", "item1-delay-03s", "item1-delay-06s"}))
+		}
 	}
 
-	g.Expect(items).To(Equal([]string{"item1", "item1-delay-05s", "item1-delay-10s"}))
+	g.Expect(items).To(Equal([]string{"item1", "item1-delay-03s", "item1-delay-06s"}))
 }
 
 func first[T1 any, T2 any](a T1, _ T2) T1 {