Lines Matching refs:err
8 …row, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _thr…
5664 ….push(_s.value); if (i && _arr.length === i) break; } } catch (err) { _d = true; _e = err; } final…
6043 …? "return" : "normal", arg); }, function (err) { resume("throw", err); }); } catch (err) { settle(…
6081 saxesParser.on('error', function (err) {
6082 error = err;
6259 …row, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _thr…
7253 fs.access(path, fs.constants.F_OK, function (err) {
7254 resolve(!err);
7497 …row, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _thr…
7911 …err; return { s: function s() { it = o[Symbol.iterator](); }, n: function n() { var step = it.next…
7919 …row, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _thr…
8368 } catch (err) {
14086 ….push(_s.value); if (i && _arr.length === i) break; } } catch (err) { _d = true; _e = err; } final…
14298 ….push(_s.value); if (i && _arr.length === i) break; } } catch (err) { _d = true; _e = err; } final…
23856 …row, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _thr…
25584 this.rowFormatter.format(row, function (err, rows) {
25585 if (err) {
25587 return cb(err);
25612 this.rowFormatter.finish(function (err, rows) {
25613 if (err) {
25614 return cb(err);
25841 this.callTransformer(row, function (err, transformedRow) {
25842 if (err) {
25843 return cb(err);
26161 }).catch(function (err) {
26162 csvStream.emit('error', err);
26375 var callNext = function callNext(err) {
26376 if (err) {
26377 return cb(err);
26409 return _this2.transformRow(row, function (err, transformResult) {
26410 if (err) {
26412 return callNext(err);
26437 this.headerTransformer.transform(parsedRow, function (err, withHeaders) {
26438 if (err) {
26439 return cb(err);
27839 validateFunction(row, function (err, isValid, reason) {
27840 if (err) {
27841 return cb(err);
40615 var err;
40624 err = e;
40626 next(err);
40631 var err;
40636 err = e;
40639 done(err);
48607 } catch (err) {
48718 var err = new Error('Unhandled "error" event. (' + er + ')');
48719 err.context = er;
48720 throw err;
49256 } catch (err) {
49257 error = err;
49268 } catch (err) {
49269 error = err;
53479 }).on('error', function (err) {
53481 reject(err);
61904 this.err = 0; // error code, if happens (0 = Z_OK)
62079 this.err = status;
62122 if (deflator.err) {
62123 throw deflator.msg || msg[deflator.err];
62294 this.err = 0; // error code, if happens (0 = Z_OK)
62509 this.err = status;
62557 if (inflator.err) {
62558 throw inflator.msg || msg[inflator.err];
63235 function err(strm, errorCode) {
64613 return err(strm, Z_STREAM_ERROR);
64685 return err(strm, Z_STREAM_ERROR);
64738 return strm ? err(strm, Z_STREAM_ERROR) : Z_STREAM_ERROR;
64744 return err(strm, strm.avail_out === 0 ? Z_BUF_ERROR : Z_STREAM_ERROR);
64999 return err(strm, Z_BUF_ERROR);
65005 return err(strm, Z_BUF_ERROR);
65124 return err(strm, Z_STREAM_ERROR);
65128 return status === BUSY_STATE ? err(strm, Z_DATA_ERROR) : Z_OK;
71270 randombytes(size, function (err, bytes) {
71271 if (err) {
71272 return cb(err);
71836 Readable.prototype._destroy = function (err, cb) {
71837 cb(err);
72935 Transform.prototype._destroy = function (err, cb) {
72936 Duplex.prototype._destroy.call(this, err, function (err2) {
73544 stream._final(function (err) {
73547 if (err) {
73548 errorOrDestroy(stream, err);
73607 function onCorkedFinish(corkReq, state, err) {
73614 cb(err);
73649 Writable.prototype._destroy = function (err, cb) {
73650 cb(err);
73799 _this2[kStream].destroy(null, function (err) {
73800 if (err) {
73801 reject(err);
73845 finished(stream, function (err) {
73846 if (err && err.code !== 'ERR_STREAM_PREMATURE_CLOSE') {
73854 reject(err);
73857 iterator[kError] = err;
74153 function destroy(err, cb) {
74161 cb(err);
74162 } else if (err) {
74164 process.nextTick(emitErrorNT, this, err);
74167 process.nextTick(emitErrorNT, this, err);
74185 this._destroy(err || null, function (err) {
74186 if (!cb && err) {
74188 process.nextTick(emitErrorAndCloseNT, _this, err);
74191 process.nextTick(emitErrorAndCloseNT, _this, err);
74197 cb(err);
74206 function emitErrorAndCloseNT(self, err) {
74207 emitErrorNT(self, err);
74236 function emitErrorNT(self, err) {
74237 self.emit('error', err);
74240 function errorOrDestroy(stream, err) {
74248 …te.autoDestroy || wState && wState.autoDestroy) stream.destroy(err);else stream.emit('error', err);
74313 var onerror = function onerror(err) {
74314 callback.call(stream, err);
74318 var err;
74321 …if (!stream._readableState || !stream._readableState.ended) err = new ERR_STREAM_PREMATURE_CLOSE();
74322 return callback.call(stream, err);
74326 …if (!stream._writableState || !stream._writableState.ended) err = new ERR_STREAM_PREMATURE_CLOSE();
74327 return callback.call(stream, err);
74392 function noop(err) {
74394 if (err) throw err;
74411 }, function (err) {
74412 if (err) return callback(err);
74417 return function (err) {
74424 callback(err || new ERR_STREAM_DESTROYED('pipe'));
74458 return destroyer(stream, reading, writing, function (err) {
74459 if (!error) error = err;
74460 if (err) destroys.forEach(call);
74554 } catch (err) {
74588 } catch (err) {
74591 arg: err
74686 }, function (err) {
74687 invoke("throw", err, resolve, reject);
75557 …err; return { s: function s() { it = o[Symbol.iterator](); }, n: function n() { var step = it.next…
76023 var err = this.makeError(message);
76027 throw err;
76029 handler(err);
77912 } catch (err) {
77913 _iterator.e(err);
77942 } catch (err) {
77943 _iterator2.e(err);
79118 Duplex.prototype._destroy = function (err, cb) {
79121 pna.nextTick(cb, err);
79385 Readable.prototype._destroy = function (err, cb) {
79387 cb(err);
80400 Transform.prototype._destroy = function (err, cb) {
80403 Duplex.prototype._destroy.call(this, err, function (err2) {
81000 stream._final(function (err) {
81003 if (err) {
81004 stream.emit('error', err);
81053 function onCorkedFinish(corkReq, state, err) {
81060 cb(err);
81094 Writable.prototype._destroy = function (err, cb) {
81096 cb(err);
81209 function destroy(err, cb) {
81217 cb(err);
81218 } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
81219 pna.nextTick(emitErrorNT, this, err);
81236 this._destroy(err || null, function (err) {
81237 if (!cb && err) {
81238 pna.nextTick(emitErrorNT, _this, err);
81244 cb(err);
81268 function emitErrorNT(self, err) {
81269 self.emit('error', err);
83209 } catch (err) {} // For CommonJS default export support