Socket
Socket
Sign inDemoInstall

@comunica/mediator-combine-pipeline

Package Overview
Dependencies
Maintainers
4
Versions
89
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@comunica/mediator-combine-pipeline - npm Package Compare versions

Comparing version 1.22.0 to 2.0.1-alpha.5.0

components/MediatorCombinePipeline.jsonld

5

lib/MediatorCombinePipeline.d.ts
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>;

4

lib/MediatorCombinePipeline.js

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc