easy-loop - npm Package Compare versions

Comparing version 1.6.0 to 1.7.0

lib/easy-loop.js

@@ -9,3 +9,3 @@ /**
 var easyPing = require('./easy-ping');
-
+var easyTick = require('./easy-tick');
 function loop(obj, func, concurrency, last){
@@ -21,2 +21,6 @@ if(typeof obj === 'function' || obj === true)
 	}
+	else if(Array.isArray(obj) && typeof func === 'number' && typeof concurrency === 'number' && typeof last === 'function')
+	{
+		easyTick(this, Array.from(arguments));
+	}
 	else
@@ -27,2 +31,41 @@ {
 }
+/**
+ * 최초에만 concurrency 숫자만큼 병렬 시작하고 그 담부턴 순차적으로 실행
+ * @param {*} obj 
+ * @param {*} concurrency 
+ * @param {*} func 
+ * @param {*} last 
+ */
+function loopOnce(obj, concurrency, func, last){
+	let len = obj.length;
+	if(concurrency >= len)
+	{
+		loop(obj, concurrency, func, last);
+	}
+	else
+	{
+		let task = obj.splice(0, concurrency);
+		len = obj.length;
+		loop(task, concurrency, func, function(err, results1){
+			if(err)
+			{
+				if(last) last(err, results1);
+			}
+			else
+			{
+				loop(obj, 1, function(i, value, next){
+					func(i+len-1, value, next);
+				}, function(err, results2){
+					if(results1)
+					{
+						if(!results2) results2 = [];
+						results1 = results1.concat(results2);
+						last(err, results1);
+					}
+					else if(last) last(err);
+				});
+			}
+		});
+	}
+}
 loop["ping"] = loop["waterfall"] = loop["for"] = loop["while"] = loop["loop"] = loop["forEach"] = loop;
@@ -32,3 +75,5 @@ loop["create"] = easyManual;
 loop["parallel"] = easyAsync.parallel;
+loop["once"] = loopOnce;
+loop["tick"] = easyTick;
 
 module.exports = loop;

package.json

 {
   "name": "easy-loop",
-  "version": "1.6.0",
+  "version": "1.7.0",
   "description": "Easy sync loop processing for Node.js",
@@ -5,0 +5,0 @@ "main": "lib/easy-loop",

test/easy-loop-test.js

@@ -486,2 +486,48 @@ //var fs = require('fs');
 222 end
-*/
+*/
+
+//Case18 Start => once parallel. after series Processing
+/*
+loop.once([1,2,3,4,5], 2, function(i, value, next){
+	setTimeout(function(){
+		console.log(i, "=", value);
+		next();
+	}, 1000);
+}, function(err, results){
+	console.log("result",arguments);
+});
+*/
+
+
+
+
+/*
+//Case19 Start => tick parallel(arg : array, tick-time(ms), concurrency, callback)
+console.log(new Date(), "start");
+loop.tick([1,2,3,4,5,6,7,8,9,10], 1000, 3, function(i, value, next){
+	console.log(new Date(), i, "=", value);
+	setTimeout(function(){
+		next();
+	}, 2000);
+}, function(err){
+	console.log(new Date(), "end", arguments);
+});
+*/
+/*
+//result
[phone]T01:43:23.774Z 'start'
[phone]T01:43:23.779Z 0 '=' 1
[phone]T01:43:23.781Z 1 '=' 2
[phone]T01:43:23.781Z 2 '=' 3
[phone]T01:43:24.782Z 3 '=' 4
[phone]T01:43:24.782Z 4 '=' 5
[phone]T01:43:24.782Z 5 '=' 6
[phone]T01:43:25.783Z 6 '=' 7
[phone]T01:43:25.784Z 7 '=' 8
[phone]T01:43:25.784Z 8 '=' 9
[phone]T01:43:26.783Z 9 '=' 10
[phone]T01:43:28.784Z 'end' { '0': null }
+*/
+
+
+

No alert changes

Improved metrics

Total package byte prevSize

37741

increased by8.69%

Number of package files

12

increased by9.09%

Lines of code

879

increased by15.96%

No dependency changes