Comparing version 0.0.1-beta.12 to 0.0.1-beta.13
@@ -20,2 +20,3 @@ "use strict"; | ||
const VError = require("verror"); | ||
const debug = require('debug')('bakeryjs:Program'); | ||
function createDrainPush(drainCallback) { | ||
@@ -97,3 +98,5 @@ return { | ||
const job = new Job_1.Job(jobInitialValue); | ||
console.log('Program run ----->'); | ||
if (debug.enabled || process.env.NODE_ENV !== 'production') { | ||
console.log('Program run ----->'); | ||
} | ||
// TODO: separate this from stats EE -- it is shared accross various flows | ||
@@ -143,5 +146,9 @@ stats_1.eventEmitter.emit('run', flow, job); | ||
: undefined; | ||
console.log('dispatch on flow description:'); | ||
if (debug.enabled || process.env.NODE_ENV !== 'production') { | ||
console.log('dispatch on flow description:'); | ||
} | ||
if (Flow_1.hasFlow(flowDesc)) { | ||
console.log('getting flow from catalog'); | ||
if (debug.enabled || process.env.NODE_ENV !== 'production') { | ||
console.log('getting flow from catalog'); | ||
} | ||
return this.catalog | ||
@@ -156,3 +163,5 @@ .getFlow(flowDesc.flow, drain) | ||
else if (Flow_1.hasProcess(flowDesc)) { | ||
console.log('building flow from SchemaObject'); | ||
if (debug.enabled || process.env.NODE_ENV !== 'production') { | ||
console.log('building flow from SchemaObject'); | ||
} | ||
return this.catalog | ||
@@ -159,0 +168,0 @@ .buildFlow(flowDesc, drain) |
@@ -13,5 +13,7 @@ "use strict"; | ||
const stats_1 = require("../stats"); | ||
// import {qTrace, sampleStats} from '../stats'; | ||
const BetterQueue = require("better-queue"); | ||
const DEFAULT_PRIORITY = undefined; | ||
let AQueue = class AQueue { | ||
// @sampleStats | ||
class AQueue { | ||
constructor(target, worker, config) { | ||
@@ -46,3 +48,3 @@ this.target = target; | ||
} | ||
}; | ||
} | ||
__decorate([ | ||
@@ -54,6 +56,2 @@ stats_1.qTrace(true), | ||
], AQueue.prototype, "push", null); | ||
AQueue = __decorate([ | ||
stats_1.sampleStats, | ||
__metadata("design:paramtypes", [String, Function, Object]) | ||
], AQueue); | ||
exports.AQueue = AQueue; | ||
@@ -60,0 +58,0 @@ class MemoryPrioritySingleQueue extends AQueue { |
{ | ||
"name": "bakeryjs", | ||
"version": "0.0.1-beta.12", | ||
"version": "0.0.1-beta.13", | ||
"description": "FBP-inspired library", | ||
@@ -34,3 +34,3 @@ "main": "build/index", | ||
"@types/better-queue": "^3.8.0", | ||
"@types/jest": "^23.3.10", | ||
"@types/jest": "^24.0.0", | ||
"@types/node": "^10.12.15", | ||
@@ -44,3 +44,2 @@ "@types/verror": "^1.10.3", | ||
"jest": "^23.6.0", | ||
"jest-junit": "^5.2.0", | ||
"json5": "^2.1.0", | ||
@@ -47,0 +46,0 @@ "nodemon": "^1.18.9", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
224205
19
3486
8
1