Method RoundTrip

modules/frontend/pipeline/responses_test.go:410–429

(r Request)

}

func (s sharder) RoundTrip(r Request) (Responses[combiner.PipelineResponse], error) {
	total := 4
	concurrent := 2

	// execute requests
	if s.funcSharder {
		return NewAsyncSharderFunc(r.HTTPRequest().Context(), concurrent, total, func(_ int) Request {
			return r
		}, s.next), nil
	}

	reqCh := make(chan Request)
	go func() {
		for i := 0; i < total; i++ {
			reqCh <- r
		}
		close(reqCh)
	}()
	return NewAsyncSharderChan(r.HTTPRequest().Context(), concurrent, reqCh, nil, s.next), nil
}

func BenchmarkNewSyncToAsyncResponse(b *testing.B) {
	r := &http.Response{}