@filemonger/main
Advanced tools
Comparing version 0.5.2 to 0.5.3
@@ -14,10 +14,12 @@ "use strict"; | ||
const resolvedDestDir = f.dir(f.abs(path_1.resolve(destDir))); | ||
const result = transform(resolvedSrcDir, resolvedDestDir, opts); | ||
if (isSubscribable(result)) { | ||
return result.map(() => { }); | ||
} | ||
if (isPromise(result)) { | ||
return rxjs_1.Observable.fromPromise(result).map(() => { }); | ||
} | ||
return rxjs_1.Observable.of(result).map(() => { }); | ||
return rxjs_1.Observable.defer(() => { | ||
const result = transform(resolvedSrcDir, resolvedDestDir, opts); | ||
if (isSubscribable(result)) { | ||
return result; | ||
} | ||
if (isPromise(result)) { | ||
return rxjs_1.Observable.fromPromise(result); | ||
} | ||
return rxjs_1.Observable.of(result); | ||
}).map(() => { }); | ||
}; | ||
@@ -24,0 +26,0 @@ const run = (destDir, done = () => { }) => writeTo(destDir).subscribe({ complete: done, error: done }); |
{ | ||
"name": "@filemonger/main", | ||
"version": "0.5.2", | ||
"version": "0.5.3", | ||
"description": "Process files with streams", | ||
@@ -30,3 +30,3 @@ "main": "dist/index.js", | ||
"devDependencies": { | ||
"@filemonger/filtermonger": "^0.5.2", | ||
"@filemonger/filtermonger": "^0.5.3", | ||
"@types/babel-core": "^6.25.3", | ||
@@ -33,0 +33,0 @@ "@types/chai": "^4.1.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
9888
210