Method SendError

modules/frontend/pipeline/responses.go:123–129

SendError sends an error to the asyncResponse. This will cause the asyncResponse to return the error on the next call to Next. we send on a channel to give errors the chance to unblock the select below. we also store in an atomic error so that a Responses in error will always remain in error

(err error)

// we send on a channel to give errors the chance to unblock the select below. we also store in an atomic error so that
// a Responses in error will always remain in error
func (a *asyncResponse) SendError(err error) {
	select {
	case a.errChan <- err:
		a.err.Store(err)
	default:
	}
}

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