Function rcvCtx

log/logrus_test.go:102–110

(ctx context.Context, t *testing.T, ch <-chan T)

}

func rcvCtx[T any](ctx context.Context, t *testing.T, ch <-chan T) (v T) {
	t.Helper()
	select {
	case <-ctx.Done():
		t.Fatal("timeout")
	case v = <-ch:
	}
	return v
}