Method SendComplete

modules/frontend/pipeline/responses.go:132–134

SendComplete indicates the sender is done. We close the channel to give a clear signal to the consumer

()

// SendComplete indicates the sender is done. We close the channel to give a clear signal to the consumer
func (a *asyncResponse) SendComplete() {
	close(a.respChan)
}

// Next returns the next http.Response or an error if one is available. It always prefers an error over a response.
// todo: review performance. There is a lot of channel access here