New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

bakeryjs

Package Overview
Dependencies
Maintainers
4
Versions
26
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

bakeryjs - npm Package Compare versions

Comparing version 0.0.1-beta.12 to 0.0.1-beta.13

17

build/lib/bakeryjs/Program.js

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

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