@comunica/mediator-combine-pipeline
Advanced tools
Comparing version 1.22.0 to 2.0.1-alpha.5.0
import type { Actor, IAction, IActorOutput, IActorTest, IMediatorArgs } from '@comunica/core'; | ||
import { Mediator } from '@comunica/core'; | ||
import type { IActionContext } from '@comunica/types'; | ||
/** | ||
@@ -7,3 +8,5 @@ * A comunica mediator that goes over all actors in sequence and forwards I/O. | ||
*/ | ||
export declare class MediatorCombinePipeline<A extends Actor<H, T, H>, H extends IAction | IActorOutput, T extends IActorTest> extends Mediator<A, H, T, H> { | ||
export declare class MediatorCombinePipeline<A extends Actor<H, T, H>, H extends IAction | (IActorOutput & { | ||
context: IActionContext; | ||
}), T extends IActorTest> extends Mediator<A, H, T, H> { | ||
constructor(args: IMediatorArgs<A, H, T, H>); | ||
@@ -10,0 +13,0 @@ mediate(action: H): Promise<H>; |
@@ -18,3 +18,3 @@ "use strict"; | ||
} | ||
catch (_a) { | ||
catch { | ||
// If no actors are available, just return the input as output | ||
@@ -29,3 +29,3 @@ return action; | ||
for (const actor of testResults.map(result => result.actor)) { | ||
handle = Object.assign(Object.assign({}, handle), await actor.runObservable(handle)); | ||
handle = { ...handle, ...await actor.runObservable(handle) }; | ||
} | ||
@@ -32,0 +32,0 @@ // Return the final actor output |
The MIT License (MIT) | ||
Copyright © 2017–2018 Ruben Taelman, Joachim Van Herwegen | ||
Ghent University – imec, Belgium | ||
Copyright © 2017–now Ruben Taelman, Joachim Van Herwegen | ||
Comunica Association and Ghent University – imec, Belgium | ||
@@ -6,0 +6,0 @@ Permission is hereby granted, free of charge, to any person obtaining a copy |
{ | ||
"name": "@comunica/mediator-combine-pipeline", | ||
"version": "1.22.0", | ||
"version": "2.0.1-alpha.5.0", | ||
"description": "A sequential combine mediator", | ||
"lsd:module": true, | ||
"main": "index.js", | ||
"typings": "index", | ||
"main": "lib/index.js", | ||
"typings": "lib/index", | ||
"repository": { | ||
@@ -28,35 +28,13 @@ "type": "git", | ||
"lib/**/*.d.ts", | ||
"lib/**/*.js", | ||
"index.d.ts", | ||
"index.js" | ||
"lib/**/*.js" | ||
], | ||
"peerDependencies": { | ||
"@comunica/core": "^1.0.0" | ||
"dependencies": { | ||
"@comunica/core": "2.0.1-alpha.5.0" | ||
}, | ||
"devDependencies": { | ||
"@comunica/core": "^1.22.0" | ||
}, | ||
"jest": { | ||
"globals": { | ||
"ts-jest": { | ||
"tsConfig": "../../tsconfig.json" | ||
} | ||
}, | ||
"transform": { | ||
"^.+\\.ts$": "ts-jest" | ||
}, | ||
"testRegex": "(/test/.*|(\\.|/)(test|spec))\\.ts$", | ||
"moduleFileExtensions": [ | ||
"ts", | ||
"js" | ||
], | ||
"collectCoverage": true | ||
}, | ||
"scripts": { | ||
"test": "node \"../../node_modules/jest/bin/jest.js\" ${1}", | ||
"test-watch": "node \"../../node_modules/jest/bin/jest.js\" ${1} --watch", | ||
"build": "node \"../../node_modules/typescript/bin/tsc\"", | ||
"validate": "npm ls" | ||
"build": "npm run build:ts && npm run build:components", | ||
"build:ts": "node \"../../node_modules/typescript/bin/tsc\"", | ||
"build:components": "componentsjs-generator" | ||
}, | ||
"gitHead": "0a249ba341022eb2f1b9922fcf549a9564671d9f" | ||
"gitHead": "e2ae2e9e924bf0656df60cc99774f7e560d47695" | ||
} |
@@ -26,3 +26,3 @@ # Comunica Mediator Sequential | ||
... | ||
"https://linkedsoftwaredependencies.org/bundles/npm/@comunica/mediator-combine-pipeline/^1.0.0/components/context.jsonld" | ||
"https://linkedsoftwaredependencies.org/bundles/npm/@comunica/mediator-combine-pipeline/^2.0.0/components/context.jsonld" | ||
], | ||
@@ -34,5 +34,5 @@ "actors": [ | ||
"someMediator": { | ||
"@id": "config-sets:sparql-init.json#mediatorOptimizeQueryOperation", | ||
"@id": "#mediatorOptimizeQueryOperation", | ||
"@type": "MediatorCombinePipeline", | ||
"cc:Mediator/bus": { "@id": "cboqo:Bus/OptimizeQueryOperation" } | ||
"bus": { "@id": "ActorOptimizeQueryOperation:_default_bus" } | ||
} | ||
@@ -46,3 +46,3 @@ } | ||
* `cc:Mediator/bus`: Identifier of the bus to mediate over. | ||
* `bus`: Identifier of the bus to mediate over. | ||
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
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
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
13838
0
65
1
+ Added@comunica/context-entries@2.0.1-alpha.5.0(transitive)
+ Added@comunica/core@2.0.1-alpha.5.0(transitive)
+ Added@comunica/types@2.0.1-alpha.5.0(transitive)
+ Added@types/http-link-header@1.0.7(transitive)
+ Added@types/node@18.19.51(transitive)
+ Added@types/yargs@17.0.33(transitive)
+ Added@types/yargs-parser@21.0.3(transitive)
+ Addedcross-fetch@3.1.8(transitive)
+ Addedhttp-link-header@1.1.3(transitive)
+ Addedjsonld-context-parser@2.4.0(transitive)
+ Addednode-fetch@2.7.0(transitive)
+ Addedrelative-to-absolute-iri@1.0.7(transitive)
+ Addedsparqlalgebrajs@4.3.8(transitive)
+ Addedtr46@0.0.3(transitive)
+ Addedundici-types@5.26.5(transitive)
+ Addedwebidl-conversions@3.0.1(transitive)
+ Addedwhatwg-url@5.0.0(transitive)
- Removed@comunica/context-entries@1.22.0(transitive)
- Removed@comunica/core@1.22.0(transitive)
- Removed@comunica/types@1.22.0(transitive)
- Removedsparqlalgebrajs@3.0.3(transitive)