Function collectItems

pkg/utilds/quickreorderqueue_test.go:11–25

(ch <-chan T, count int, timeout time.Duration)

)

func collectItems[T any](ch <-chan T, count int, timeout time.Duration) []T {
	result := make([]T, 0, count)
	timer := time.NewTimer(timeout)
	defer timer.Stop()

	for i := 0; i < count; i++ {
		select {
		case item := <-ch:
			result = append(result, item)
		case <-timer.C:
			return result
		}
	}
	return result
}

func TestQuickReorderQueue_InOrder(t *testing.T) {
	q := MakeQuickReorderQueue[string](10, 100*time.Millisecond)