Function newAsyncResponse

modules/frontend/pipeline/responses.go:105–111

()

}

func newAsyncResponse() *asyncResponse {
	return &asyncResponse{
		respChan: make(chan Responses[combiner.PipelineResponse]),
		errChan:  make(chan error, 1),
		err:      atomic.NewError(nil),
	}
}

func (a *asyncResponse) Send(ctx context.Context, r Responses[combiner.PipelineResponse]) {
	select {