Function ExpectDrainedChan

internal/th/assertions.go:107–117

(t *testing.T, ch <-chan A)

}

func ExpectDrainedChan[A any](t *testing.T, ch <-chan A) {
	t.Helper()
	select {
	case x, ok := <-ch:
		if ok {
			t.Errorf("expected channel to be closed, but got %v", x)
		}
	default:
		t.Errorf("expected channel to be closed, but it's blocked")
	}
}

func ExpectNeverClosedChan[A any](t *testing.T, ch <-chan A, waitFor time.Duration) {
	t.Helper()