Comparing version 0.9.5 to 0.9.6
@@ -177,5 +177,4 @@ var _ = require("./_"); | ||
var iter = genIterator(iterable); | ||
return new Observable(function (emit) { | ||
var result = [], count, len = 0, item; | ||
var result = [], marked = [], count, len = 0, item; | ||
@@ -186,6 +185,11 @@ function onEmit (i) { | ||
if (!count--) { | ||
if (marked[i]) return; | ||
marked[i] = true; | ||
if (!--count) { | ||
emit(result); | ||
count = len; | ||
result = []; | ||
marked = []; | ||
} | ||
@@ -199,8 +203,10 @@ }; | ||
result = []; | ||
marked = []; | ||
} | ||
while (!(item = iter.next()).done) { | ||
item.value.subscribe(onEmit(count = len++), onError); | ||
item.value.subscribe(onEmit(len++), onError); | ||
} | ||
count = len; | ||
}); | ||
}; |
/* | ||
Yaku v0.9.5 | ||
Yaku v0.9.6 | ||
(c) 2015 Yad Smood. http://ysmood.org | ||
@@ -4,0 +4,0 @@ License MIT |
{ | ||
"name": "yaku", | ||
"version": "0.9.5", | ||
"version": "0.9.6", | ||
"description": "A light-weight ES6 Promises/A+ implementation that doesn't hurt.", | ||
@@ -40,5 +40,5 @@ "main": "lib/yaku.js", | ||
"devDependencies": { | ||
"bluebird": "2.10.1", | ||
"bluebird": "2.10.2", | ||
"es6-promise": "3.0.2", | ||
"eslint": "1.5.1", | ||
"eslint": "1.6.0", | ||
"junit": "0.6.1", | ||
@@ -48,3 +48,3 @@ "nokit": "0.14.7", | ||
"q": "1.4.1", | ||
"uglify-js": "2.4.24", | ||
"uglify-js": "2.5.0", | ||
"webpack": "1.12.2" | ||
@@ -51,0 +51,0 @@ }, |
74076
1402