Lines Matching refs:er
71 stream[kFs].open(stream.path, stream.flags, stream.mode, (er, fd) => {
72 if (er) {
73 callback(er);
117 stream[kFs].close(stream.fd, (er) => {
118 cb(er || err);
250 .read(this.fd, buf, 0, n, this.pos, (er, bytesRead, buf) => {
255 this.emit(kIoDone, er);
259 if (er) {
260 errorOrDestroy(this, er);
292 this.once(kIoDone, (er) => close(this, err || er, cb));
398 this[kFs].write(this.fd, data, 0, size, pos, (er, bytesWritten, buffer) => {
400 if (er?.code === 'EAGAIN') {
401 er = null;
405 if (this.destroyed || er) {
406 return cb(er || new ERR_STREAM_DESTROYED('write'));
427 this[kFs].writev(this.fd, chunks, this.pos, (er, bytesWritten, buffers) => {
429 if (er?.code === 'EAGAIN') {
430 er = null;
434 if (this.destroyed || er) {
435 return cb(er || new ERR_STREAM_DESTROYED('writev'));
457 writeAll.call(this, data, data.length, this.pos, (er) => {
461 cb(er);
462 return this.emit(kIoDone, er);
465 cb(er);
485 writevAll.call(this, chunks, size, this.pos, (er) => {
489 cb(er);
490 return this.emit(kIoDone, er);
493 cb(er);
508 this.once(kIoDone, (er) => close(this, err || er, cb));