Comparing version 1.0.3 to 1.0.4
@@ -12,14 +12,14 @@ | ||
super(left); | ||
this.funRight = funRight; | ||
this.funJoin = funJoin; | ||
} | ||
_createTransformer (leftItem) | ||
{ | ||
return new SimpleTransformIterator(this.funRight(leftItem), { transform: (rightItem, done) => | ||
return new SimpleTransformIterator(this.funRight(leftItem), { transform: (rightItem, done, push) => | ||
{ | ||
let result = this.funJoin(leftItem, rightItem); | ||
if (result !== null) | ||
this._push(result); | ||
push(result); | ||
done(); | ||
@@ -30,2 +30,2 @@ }}); | ||
module.exports = DynamicNestedLoopJoin; | ||
module.exports = DynamicNestedLoopJoin; |
@@ -24,7 +24,7 @@ | ||
{ | ||
return new SimpleTransformIterator(this.right.clone(), { transform: (rightItem, done) => | ||
return new SimpleTransformIterator(this.right.clone(), { transform: (rightItem, done, push) => | ||
{ | ||
let result = this.funJoin(leftItem, rightItem); | ||
if (result !== null) | ||
this._push(result); | ||
push(result); | ||
done(); | ||
@@ -31,0 +31,0 @@ }}); |
{ | ||
"name": "asyncjoin", | ||
"version": "1.0.3", | ||
"version": "1.0.4", | ||
"description": "Join library for asynciterator", | ||
@@ -11,6 +11,6 @@ "license": "MIT", | ||
"dependencies": { | ||
"asynciterator": "^3.0.0" | ||
"asynciterator": "^3.2.0" | ||
}, | ||
"devDependencies": { | ||
"lodash": "^4.17.10", | ||
"lodash": "^4.17.21", | ||
"mocha": "^5.2.0", | ||
@@ -17,0 +17,0 @@ "pre-commit": "^1.2.2" |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
321
11845
Updatedasynciterator@^3.2.0