Function TestErrorsPropagateUpstream

modules/frontend/v1/request_batch_test.go:131–156

(t *testing.T)

}

func TestErrorsPropagateUpstream(t *testing.T) {
	rb := &requestBatch{}

	const totalRequests = 3
	wg := &sync.WaitGroup{}

	for i := 0; i < totalRequests-1; i++ {
		errChan := make(chan error)

		wg.Add(1)
		go func() {
			err := <-errChan
			require.ErrorContains(t, err, "foo")
			wg.Done()
		}()
		req := httptest.NewRequest("GET", "http://example.com", nil)
		_ = rb.add(&request{
			request: pipeline.NewHTTPRequest(req),
			err:     errChan,
		})
	}

	rb.reportErrorToPipeline(errors.New("foo"))
	wg.Wait()
	// this test won't return unless all errChan's receive an error
}

func TestResponsesPropagateUpstream(t *testing.T) {
	rb := &requestBatch{}