promise-stream-queue - npm Package Compare versions

Comparing version 0.2.1 to 0.2.2

examples/async.js

@@ -0,0 +0,0 @@ const Stream = require('../main.js');

examples/sync.js

@@ -0,0 +0,0 @@ const

item.js

@@ -77,10 +77,15 @@ function Item(id,pr,timeout) {
 
-	this.pr.then(thenhdl,errhdl).catch(catchhdl);
-	if(this.timeout>0) {
-		to = setTimeout(()=>{
-			self.kill("Promise timeout");
-		},this.timeout);
-	};
+	if(this.pr.then) {
+		this.pr.then(thenhdl,errhdl).catch(catchhdl);
+		if(this.timeout>0) {
+			to = setTimeout(()=>{
+				self.kill("Promise timeout");
+			},this.timeout);
+		};
+	}
+	else {
+		thenhdl(this.pr);
+	}
 }
 
 module.exports = Item;

main.js

@@ -0,0 +0,0 @@ const

package.json

 {
   "name": "promise-stream-queue",
-  "version": "0.2.1",
+  "version": "0.2.2",
   "description": "Promise Stream. Queue promises and retrieve the resolved/rejected ones in the inserted order",
@@ -5,0 +5,0 @@ "author": "David Gómez Matarrodona <[e-mail]>",

README.md

@@ -0,0 +0,0 @@ # promise-stream-queue

No alert changes

Improved metrics

Lines of code

211

2.43%

Worsened metrics

Total package byte prevSize

12012

-3.21%

No dependency changes