Function addResponses

modules/frontend/pipeline/responses_test.go:196–213

(r *asyncResponse)

}

func addResponses(r *asyncResponse) int {
	responsesToAdd := rand.Intn(5)
	childResponse := newAsyncResponse()
	defer childResponse.SendComplete()

	ctx := context.Background()
	r.Send(ctx, childResponse)
	for i := 0; i < responsesToAdd; i++ {
		childResponse.Send(ctx, NewHTTPToAsyncResponse(&http.Response{}))
	}

	recurse := rand.Intn(2)%2 == 0
	if recurse {
		return responsesToAdd + addResponses(childResponse)
	}

	return responsesToAdd
}

func TestAsyncResponsesDoesNotLeak(t *testing.T) {
	tcs := []struct {