Lines Matching refs:cb
87 open: (path, flags, mode, cb) => {
90 close: (fd, cb) => {
93 () => cb(), cb);
95 read: (fd, buf, offset, length, pos, cb) => {
97 (r) => cb(null, r.bytesRead, r.buffer),
98 (err) => cb(err, 0, buf));
100 write: (fd, buf, offset, length, pos, cb) => {
102 (r) => cb(null, r.bytesWritten, r.buffer),
103 (err) => cb(err, 0, buf));
105 writev: (fd, buffers, pos, cb) => {
107 (r) => cb(null, r.bytesWritten, r.buffers),
108 (err) => cb(err, 0, buffers));
113 function close(stream, err, cb) {
115 cb(err);
118 cb(er || err);
284 ReadStream.prototype._destroy = function(err, cb) {
292 this.once(kIoDone, (er) => close(this, err || er, cb));
294 close(this, err, cb);
298 ReadStream.prototype.close = function(cb) {
299 if (typeof cb === 'function') finished(this, cb);
397 function writeAll(data, size, pos, cb, retries = 0) {
406 return cb(er || new ERR_STREAM_DESTROYED('write'));
417 cb(new ERR_SYSTEM_ERROR('write failed'));
419 writeAll.call(this, buffer.slice(bytesWritten), size, pos, cb, retries);
421 cb();
426 function writevAll(chunks, size, pos, cb, retries = 0) {
435 return cb(er || new ERR_STREAM_DESTROYED('writev'));
446 cb(new ERR_SYSTEM_ERROR('writev failed'));
448 writevAll.call(this, [Buffer.concat(buffers).slice(bytesWritten)], size, pos, cb, retries);
450 cb();
455 WriteStream.prototype._write = function(data, encoding, cb) {
461 cb(er);
465 cb(er);
472 WriteStream.prototype._writev = function(data, cb) {
489 cb(er);
493 cb(er);
500 WriteStream.prototype._destroy = function(err, cb) {
508 this.once(kIoDone, (er) => close(this, err || er, cb));
510 close(this, err, cb);
514 WriteStream.prototype.close = function(cb) {
515 if (cb) {
517 process.nextTick(cb);
520 this.on('close', cb);