using node:timers setImmediate instead of relying on the global provided one as is deprecated in some systems

Author: danyg

fd-slicer.js

@@ -7,6 +7,7 @@ var Writable = stream.Writable;
 var PassThrough = stream.PassThrough;
 var Pend = require('pend');
 var EventEmitter = require('events').EventEmitter;
+var setImmediate = require("timers").setImmediate;
 
 exports.createFromBuffer = createFromBuffer;
 exports.createFromFd = createFromFd;
@@ -25,39 +26,39 @@ function FdSlicer(fd, options) {
   this.autoClose = !!options.autoClose;
 }
 
-FdSlicer.prototype.read = function(buffer, offset, length, position, callback) {
+FdSlicer.prototype.read = function (buffer, offset, length, position, callback) {
   var self = this;
-  self.pend.go(function(cb) {
-    fs.read(self.fd, buffer, offset, length, position, function(err, bytesRead, buffer) {
+  self.pend.go(function (cb) {
+    fs.read(self.fd, buffer, offset, length, position, function (err, bytesRead, buffer) {
       cb();
       callback(err, bytesRead, buffer);
     });
   });
 };
 
-FdSlicer.prototype.write = function(buffer, offset, length, position, callback) {
+FdSlicer.prototype.write = function (buffer, offset, length, position, callback) {
   var self = this;
-  self.pend.go(function(cb) {
-    fs.write(self.fd, buffer, offset, length, position, function(err, written, buffer) {
+  self.pend.go(function (cb) {
+    fs.write(self.fd, buffer, offset, length, position, function (err, written, buffer) {
       cb();
       callback(err, written, buffer);
     });
   });
 };
 
-FdSlicer.prototype.createReadStream = function(options) {
+FdSlicer.prototype.createReadStream = function (options) {
   return new ReadStream(this, options);
 };
 
-FdSlicer.prototype.createWriteStream = function(options) {
+FdSlicer.prototype.createWriteStream = function (options) {
   return new WriteStream(this, options);
 };
 
-FdSlicer.prototype.ref = function() {
+FdSlicer.prototype.ref = function () {
   this.refCount += 1;
 };
 
-FdSlicer.prototype.unref = function() {
+FdSlicer.prototype.unref = function () {
   var self = this;
   self.refCount -= 1;
 
@@ -91,7 +92,7 @@ function ReadStream(context, options) {
   this.destroyed = false;
 }
 
-ReadStream.prototype._read = function(n) {
+ReadStream.prototype._read = function (n) {
   var self = this;
   if (self.destroyed) return;
 
@@ -105,10 +106,10 @@ ReadStream.prototype._read = function(n) {
     self.context.unref();
     return;
   }
-  self.context.pend.go(function(cb) {
+  self.context.pend.go(function (cb) {
     if (self.destroyed) return cb();
     var buffer = Buffer.allocUnsafe(toRead);
-    fs.read(self.context.fd, buffer, 0, toRead, self.pos, function(err, bytesRead) {
+    fs.read(self.context.fd, buffer, 0, toRead, self.pos, function (err, bytesRead) {
       if (err) {
         self.destroy(err);
       } else if (bytesRead === 0) {
@@ -124,7 +125,7 @@ ReadStream.prototype._read = function(n) {
   });
 };
 
-ReadStream.prototype.destroy = function(err) {
+ReadStream.prototype.destroy = function (err) {
   if (this.destroyed) return;
   err = err || new Error("stream destroyed");
   this.destroyed = true;
@@ -149,7 +150,7 @@ function WriteStream(context, options) {
   this.on('finish', this.destroy.bind(this));
 }
 
-WriteStream.prototype._write = function(buffer, encoding, callback) {
+WriteStream.prototype._write = function (buffer, encoding, callback) {
   var self = this;
   if (self.destroyed) return;
 
@@ -160,9 +161,9 @@ WriteStream.prototype._write = function(buffer, encoding, callback) {
     callback(err);
     return;
   }
-  self.context.pend.go(function(cb) {
+  self.context.pend.go(function (cb) {
     if (self.destroyed) return cb();
-    fs.write(self.context.fd, buffer, 0, buffer.length, self.pos, function(err, bytes) {
+    fs.write(self.context.fd, buffer, 0, buffer.length, self.pos, function (err, bytes) {
       if (err) {
         self.destroy();
         cb();
@@ -178,7 +179,7 @@ WriteStream.prototype._write = function(buffer, encoding, callback) {
   });
 };
 
-WriteStream.prototype.destroy = function() {
+WriteStream.prototype.destroy = function () {
   if (this.destroyed) return;
   this.destroyed = true;
   this.context.unref();
@@ -194,7 +195,7 @@ function BufferSlicer(buffer, options) {
   this.maxChunkSize = options.maxChunkSize || Number.MAX_SAFE_INTEGER;
 }
 
-BufferSlicer.prototype.read = function(buffer, offset, length, position, callback) {
+BufferSlicer.prototype.read = function (buffer, offset, length, position, callback) {
   if (!(0 <= offset && offset <= buffer.length)) throw new RangeError("offset outside buffer: 0 <= " + offset + " <= " + buffer.length);
   if (position < 0) throw new RangeError("position is negative: " + position);
   if (offset + length > buffer.length) {
@@ -210,25 +211,25 @@ BufferSlicer.prototype.read = function(buffer, offset, length, position, callbac
   if (length <= 0) {
     // After any clamping, we're fully out of bounds or otherwise have nothing to do.
     // This isn't an error; it's just zero bytes written.
-    setImmediate(function() {
+    setImmediate(function () {
       callback(null, 0);
     });
     return;
   }
   this.buffer.copy(buffer, offset, position, position + length);
-  setImmediate(function() {
+  setImmediate(function () {
     callback(null, length);
   });
 };
 
-BufferSlicer.prototype.write = function(buffer, offset, length, position, callback) {
+BufferSlicer.prototype.write = function (buffer, offset, length, position, callback) {
   buffer.copy(this.buffer, position, offset, offset + length);
-  setImmediate(function() {
+  setImmediate(function () {
     callback(null, length, buffer);
   });
 };
 
-BufferSlicer.prototype.createReadStream = function(options) {
+BufferSlicer.prototype.createReadStream = function (options) {
   options = options || {};
   var readStream = new PassThrough(options);
   readStream.destroyed = false;
@@ -254,13 +255,13 @@ BufferSlicer.prototype.createReadStream = function(options) {
   }
 
   readStream.end();
-  readStream.destroy = function() {
+  readStream.destroy = function () {
     readStream.destroyed = true;
   };
   return readStream;
 };
 
-BufferSlicer.prototype.createWriteStream = function(options) {
+BufferSlicer.prototype.createWriteStream = function (options) {
   var bufferSlicer = this;
   options = options || {};
   var writeStream = new Writable(options);
@@ -269,7 +270,7 @@ BufferSlicer.prototype.createWriteStream = function(options) {
   writeStream.bytesWritten = 0;
   writeStream.pos = writeStream.start;
   writeStream.destroyed = false;
-  writeStream._write = function(buffer, encoding, callback) {
+  writeStream._write = function (buffer, encoding, callback) {
     if (writeStream.destroyed) return;
 
     var end = writeStream.pos + buffer.length;
@@ -287,17 +288,17 @@ BufferSlicer.prototype.createWriteStream = function(options) {
     writeStream.emit('progress');
     callback();
   };
-  writeStream.destroy = function() {
+  writeStream.destroy = function () {
     writeStream.destroyed = true;
   };
   return writeStream;
 };
 
-BufferSlicer.prototype.ref = function() {
+BufferSlicer.prototype.ref = function () {
   this.refCount += 1;
 };
 
-BufferSlicer.prototype.unref = function() {
+BufferSlicer.prototype.unref = function () {
   this.refCount -= 1;
 
   if (this.refCount < 0) {