@comunica/mediator-combine-pipeline
Advanced tools
Comparing version 1.1.0 to 1.2.0
@@ -13,3 +13,10 @@ "use strict"; | ||
async mediate(action) { | ||
const testResults = this.publish(action); | ||
let testResults; | ||
try { | ||
testResults = this.publish(action); | ||
} | ||
catch (e) { | ||
// If no actors are available, just return the input as output | ||
return action; | ||
} | ||
// Delegate test errors. | ||
@@ -21,3 +28,3 @@ await Promise.all(require('lodash.map')(testResults, 'reply')); | ||
for (const actor of testResults.map((result) => result.actor)) { | ||
handle = await actor.run(handle); | ||
handle = await actor.runObservable(handle); | ||
} | ||
@@ -24,0 +31,0 @@ // Return the final actor output |
{ | ||
"name": "@comunica/mediator-combine-pipeline", | ||
"version": "1.1.0", | ||
"version": "1.2.0", | ||
"description": "A sequential combine mediator", | ||
@@ -8,4 +8,7 @@ "lsd:module": "https://linkedsoftwaredependencies.org/bundles/npm/@comunica/mediator-combine-pipeline", | ||
"lsd:contexts": { | ||
"https://linkedsoftwaredependencies.org/contexts/comunica-mediator-combine-pipeline.jsonld": "components/context.jsonld" | ||
"https://linkedsoftwaredependencies.org/bundles/npm/@comunica/mediator-combine-pipeline/^1.0.0/components/context.jsonld": "components/context.jsonld" | ||
}, | ||
"lsd:importPaths": { | ||
"https://linkedsoftwaredependencies.org/bundles/npm/@comunica/mediator-combine-pipeline/^1.0.0/components/": "components/" | ||
}, | ||
"main": "index.js", | ||
@@ -40,11 +43,8 @@ "typings": "index", | ||
"devDependencies": { | ||
"@comunica/core": "^1.1.0" | ||
"@comunica/core": "^1.2.0" | ||
}, | ||
"jest": { | ||
"transform": { | ||
"^.+\\.ts$": "<rootDir>/../../node_modules/ts-jest/preprocessor.js" | ||
"^.+\\.ts$": "ts-jest" | ||
}, | ||
"transformIgnorePatterns": [ | ||
"[/\\\\]node_modules[/\\\\].+\\.(js|jsx)$" | ||
], | ||
"testRegex": "(/test/.*|(\\.|/)(test|spec))\\.ts$", | ||
@@ -62,5 +62,4 @@ "moduleFileExtensions": [ | ||
"build": "node \"../../node_modules/typescript/bin/tsc\"", | ||
"validate": "npm ls", | ||
"prepare": "npm run build" | ||
"validate": "npm ls" | ||
} | ||
} |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
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
6203
53