Function TestAsyncQueue_QueueFullError

cache/async_queue_test.go:29–52

(t *testing.T)

}

func TestAsyncQueue_QueueFullError(t *testing.T) {
	const queueLength = 10

	q := newAsyncQueue(queueLength, 1)
	defer q.stop()

	doneCh := make(chan struct{})
	defer func() {
		close(doneCh)
	}()

	// Keep worker busy.
	_ = q.submit(func() {
		<-doneCh
	})
	time.Sleep(100 * time.Millisecond)

	// Fill the queue.
	for i := 0; i < queueLength; i++ {
		require.NoError(t, q.submit(func() {}))
	}

	require.ErrorIs(t, q.submit(func() {}), errAsyncQueueFull)
}