Method RoundTrip

modules/frontend/pipeline/pipeline.go:183–195

(req Request)

}

func (b *pipelineBridge) RoundTrip(req Request) (Responses[combiner.PipelineResponse], error) {
	r, err := b.next.RoundTrip(req)
	if err != nil {
		return nil, err
	}

	// check for request data in the context and echo it back if it exists
	if val := req.ResponseData(); val != nil {
		return NewHTTPToAsyncResponseWithRequestData(r, val), nil
	}

	return NewHTTPToAsyncResponse(r), nil
}