contentType = strings.TrimSpace(strings.SplitN(contentType, ";", 2)[0])
		}
	}
	flush = s.Flush
	stream = resp.Body
	return
}

// PreventRedirects is a redirect checker that prevents the client from following a redirect.
func PreventRedirects(_ *http.Request, _ []*http.Request) error {
	return errors.New("redirects forbidden")

		Flush:                                 logOpts.Follow,
		ResponseChecker:                       genericrest.NewGenericHttpResponseChecker(api.Resource("pods/log"), name),
		RedirectChecker:                       genericrest.PreventRedirects,
		TLSVerificationErrorCounter:           podLogsTLSFailure,
		DeprecatedTLSVerificationErrorCounter: deprecatedPodLogsTLSFailure,
	}, nil
}

func countSkipTLSMetric(insecureSkipTLSVerifyBackend bool) {

		}
	}))
	loc, err := url.Parse(s.URL)
	require.NoError(t, err, "Error parsing server URL")

	streamer := &LocationStreamer{
		Location:        loc,
		RedirectChecker: PreventRedirects,
	}
	_, _, _, err = streamer.InputStream(context.Background(), "", "")
	assert.Error(t, err, "Redirect should trigger an error")