Function NewHTTPCollector

modules/frontend/pipeline/collector_http.go:24–30

todo: long term this should return an http.Handler instead of a RoundTripper? that way it can completely encapsulate all the responsibilities of converting a pipeline http.Response and error into an http.Response to be NewHTTPCollector returns a new http collector

(next AsyncRoundTripper[combiner.PipelineResponse], consumers int, combiner combiner.Combiner)

// NewHTTPCollector returns a new http collector
func NewHTTPCollector(next AsyncRoundTripper[combiner.PipelineResponse], consumers int, combiner combiner.Combiner) http.RoundTripper {
	return httpCollector{
		next:      next,
		combiner:  combiner,
		consumers: consumers,
	}
}

// RoundTrip implements the http.RoundTripper interface
func (r httpCollector) RoundTrip(req *http.Request) (*http.Response, error) {