Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
beforeEach(() => {
out = noflo.internalSocket.createSocket();
err = noflo.internalSocket.createSocket();
c.outPorts.out.attach(out);
c.outPorts.error.attach(err);
});
afterEach(() => {
beforeEach(() => {
err = noflo.internalSocket.createSocket();
c.outPorts.error.attach(err);
});
afterEach(() => {
beforeEach(() => {
nameIn = noflo.internalSocket.createSocket();
valueOut = noflo.internalSocket.createSocket();
c.inPorts.name.attach(nameIn);
c.outPorts.value.attach(valueOut);
});
beforeEach(() => {
out = noflo.internalSocket.createSocket();
err = noflo.internalSocket.createSocket();
c.outPorts.out.attach(out);
c.outPorts.error.attach(err);
});
afterEach(() => {
loader.load('core/RunInterval', (err, instance) => {
if (err) {
done(err);
return;
}
c = instance;
interval = noflo.internalSocket.createSocket();
c.inPorts.interval.attach(interval);
start = noflo.internalSocket.createSocket();
c.inPorts.start.attach(start);
stop = noflo.internalSocket.createSocket();
c.inPorts.stop.attach(stop);
done();
});
});
c.once('ready', function () {
module = noflo.internalSocket.createSocket();
container = noflo.internalSocket.createSocket();
props = noflo.internalSocket.createSocket();
event = noflo.internalSocket.createSocket();
error = noflo.internalSocket.createSocket();
c.inPorts.module.attach(module);
c.inPorts.container.attach(container);
c.inPorts.props.attach(props);
c.outPorts.event.attach(event);
c.outPorts.error.attach(error);
c.start(done);
});
});
loader.load('core/RunTimeout', (err, instance) => {
if (err) {
done(err);
return;
}
c = instance;
start = noflo.internalSocket.createSocket();
c.inPorts.start.attach(start);
time = noflo.internalSocket.createSocket();
c.inPorts.time.attach(time);
done();
});
});
loader.load('core/Callback', (e, instance) => {
if (e) {
done(e);
return;
}
c = instance;
ins = noflo.internalSocket.createSocket();
cb = noflo.internalSocket.createSocket();
c.inPorts.in.attach(ins);
c.inPorts.callback.attach(cb);
done();
});
});
loader.load('core/Drop', (err, instance) => {
if (err) {
done(err);
return;
}
c = instance;
ins = noflo.internalSocket.createSocket();
c.inPorts.in.attach(ins);
done();
});
});
c.once('ready', function () {
module = noflo.internalSocket.createSocket();
container = noflo.internalSocket.createSocket();
props = noflo.internalSocket.createSocket();
event = noflo.internalSocket.createSocket();
error = noflo.internalSocket.createSocket();
c.inPorts.module.attach(module);
c.inPorts.container.attach(container);
c.inPorts.props.attach(props);
c.outPorts.event.attach(event);
c.outPorts.error.attach(error);
c.start(done);
});
});