fileq - npm Package Compare versions

Comparing version 1.3.2 to 1.4.0

index.js

@@ -63,4 +63,12 @@ const
 	}
+
+	close() {
+		return this.queue.close();
+	}
+
+	get closed() {
+		return this.queue.closed;
+	}	
 }
 
 module.exports = FileQueue;

lib/queue.js

@@ -93,2 +93,6 @@ const
 
+	get closed() {
+		return this.db.isClosed();
+	}
+	
 	async lock(callback) {
@@ -103,2 +107,8 @@ await this.mutex.take();
 
+	close() {
+		return new Promise((ok,rej)=>{
+			this.db.close(err=>err?rej(err):ok());
+		});
+	}
+
 	async push(data,callback) {
@@ -105,0 +115,0 @@ try {

package.json

 {
   "name": "fileq",
-  "version": "1.3.2",
+  "version": "1.4.0",
   "description": "File based FIFO queue",
@@ -5,0 +5,0 @@ "author": "David Gómez Matarrodona <[e-mail]>",

README.md

@@ -164,5 +164,11 @@ # fileq
 
+### queue.close() => Promise
+Closes de queue
+
 ### queue.locked => Boolean
 Returns *true* if queue has a virtual lock; *false* otherwise.
 
+### queue.closed => Boolean
+Returns *true* if the queue has been closed
+
 ## Options
@@ -169,0 +175,0 @@ When creating a queue, data are stored in several files in a folder.

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

19650

increased by1.98%

Lines of code

480

increased by3%

Number of lines in readme file

183

increased by3.39%

No dependency changes