diff --git a/lib/native/query.js b/lib/native/query.js index dbcd5604..7602d161 100644 --- a/lib/native/query.js +++ b/lib/native/query.js @@ -50,21 +50,20 @@ var errorFieldMap = { } NativeQuery.prototype.handleError = function (err) { - var self = this // copy pq error fields into the error object - var fields = self.native.pq.resultErrorFields() + var fields = this.native.pq.resultErrorFields() if (fields) { for (var key in fields) { var normalizedFieldName = errorFieldMap[key] || key err[normalizedFieldName] = fields[key] } } - if (self.callback) { - self.callback(err) + if (this.callback) { + this.callback(err) } else { - self.emit('error', err) + this.emit('error', err) } - self.state = 'error' + this.state = 'error' } NativeQuery.prototype.then = function (onSuccess, onFailure) {