Function TestPriorityQueueClose

pkg/util/priority_queue_test.go:80–92

(t *testing.T)

}

func TestPriorityQueueClose(t *testing.T) {
	queue := NewPriorityQueue(nil)
	queue.Enqueue(simpleItem(1))
	queue.Close()
	assert.Panics(t, func() { queue.Enqueue(simpleItem(2)) })
	assert.Equal(t, simpleItem(1), queue.Dequeue().(simpleItem))

	queue = NewPriorityQueue(nil)
	queue.Enqueue(simpleItem(1))
	queue.DiscardAndClose()
	assert.Panics(t, func() { queue.Enqueue(simpleItem(2)) })
	assert.Nil(t, queue.Dequeue())
}