Skip to content

Commit

Permalink
Merge pull request #141 from noflo/updates
Browse files Browse the repository at this point in the history
Updates
  • Loading branch information
bergie committed Oct 1, 2019
2 parents 3ac72c6 + 88833ca commit 4236a2f
Show file tree
Hide file tree
Showing 11 changed files with 31 additions and 31 deletions.
2 changes: 1 addition & 1 deletion components/RepeatDelayed.js
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ exports.getComponent = () => {
});

c.tearDown = (callback) => {
c.timers.forEach(timer => clearTimeout(timer));
c.timers.forEach((timer) => clearTimeout(timer));
c.timers = [];
return callback();
};
Expand Down
2 changes: 1 addition & 1 deletion components/RunTimeout.js
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ exports.getComponent = () => {
};

c.tearDown = (callback) => {
Object.keys(c.timer).forEach(scope => c.stopTimer(scope));
Object.keys(c.timer).forEach((scope) => c.stopTimer(scope));
callback();
};

Expand Down
8 changes: 4 additions & 4 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -34,15 +34,15 @@
"devDependencies": {
"chai": "^4.0.0",
"coveralls": "^3.0.0",
"eslint": "^5.0.1",
"eslint-config-airbnb-base": "^13.0.0",
"eslint": "^6.5.1",
"eslint-config-airbnb-base": "^14.0.0",
"eslint-plugin-chai": "0.0.1",
"eslint-plugin-import": "^2.12.0",
"eslint-plugin-mocha": "^5.2.0",
"eslint-plugin-mocha": "^6.1.1",
"fbp-spec": "^0.6.0",
"karma": "^4.0.0",
"karma-chai": "^0.1.0",
"karma-chrome-launcher": "^2.2.0",
"karma-chrome-launcher": "^3.1.0",
"karma-mocha": "^1.3.0",
"karma-mocha-reporter": "^2.2.5",
"mocha": "^6.0.0",
Expand Down
8 changes: 4 additions & 4 deletions spec/mocha/DisconnectAfterPacket.js
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,8 @@ describe('DisconnectAfterPacket component', () => {
'DISC',
];
const received = [];
out.on('begingroup', group => received.push(`< ${group}`));
out.on('data', data => received.push(`DATA ${data}`));
out.on('begingroup', (group) => received.push(`< ${group}`));
out.on('data', (data) => received.push(`DATA ${data}`));
out.on('endgroup', () => received.push('>'));
out.on('disconnect', () => {
received.push('DISC');
Expand Down Expand Up @@ -75,8 +75,8 @@ describe('DisconnectAfterPacket component', () => {
];
const received = [];
out.on('connect', () => received.push('CONN'));
out.on('begingroup', group => received.push(`< ${group}`));
out.on('data', data => received.push(`DATA ${data}`));
out.on('begingroup', (group) => received.push(`< ${group}`));
out.on('data', (data) => received.push(`DATA ${data}`));
out.on('endgroup', () => received.push('>'));
out.on('disconnect', () => {
received.push('DISC');
Expand Down
6 changes: 3 additions & 3 deletions spec/mocha/Kick.js
Original file line number Diff line number Diff line change
Expand Up @@ -117,8 +117,8 @@ describe('Kick component', () => {
];
const received = [];
out.on('connect', () => received.push('CONN'));
out.on('begingroup', group => received.push(`< ${group}`));
out.on('data', d => received.push(`DATA ${JSON.stringify(d)}`));
out.on('begingroup', (group) => received.push(`< ${group}`));
out.on('data', (d) => received.push(`DATA ${JSON.stringify(d)}`));
out.on('endgroup', () => received.push('>'));
out.on('disconnect', () => {
received.push('DISC');
Expand All @@ -127,7 +127,7 @@ describe('Kick component', () => {
});

data.send({ foo: 'bar' });
['foo', 'bar'].forEach(grp => ins.beginGroup(grp));
['foo', 'bar'].forEach((grp) => ins.beginGroup(grp));
ins.send('foo');
['foo', 'bar'].forEach(() => ins.endGroup());
ins.disconnect();
Expand Down
10 changes: 5 additions & 5 deletions spec/mocha/MakeFunction.js
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ describe('MakeFunction component', () => {
chai.expect(data(2)).to.equal(4);
done();
});
err.on('data', data => done(data));
err.on('data', (data) => done(data));
func.send('return x*x;');
});
});
Expand All @@ -81,7 +81,7 @@ describe('MakeFunction component', () => {
chai.expect(data).to.equal(81);
done();
});
err.on('data', data => done(data));
err.on('data', (data) => done(data));
func.send('return x*x;');
ins.send(9);
ins.disconnect();
Expand All @@ -93,18 +93,18 @@ describe('MakeFunction component', () => {
chai.expect(data).to.equal('99');
done();
});
err.on('data', data => done(data));
err.on('data', (data) => done(data));
ins.send('9');
ins.disconnect();
});

it('pass function', (done) => {
func.send(x => `${x}!`);
func.send((x) => `${x}!`);
out.on('data', (data) => {
chai.expect(data).to.equal('hello function!');
done();
});
err.on('data', data => done(data));
err.on('data', (data) => done(data));
ins.send('hello function');
ins.disconnect();
});
Expand Down
4 changes: 2 additions & 2 deletions spec/mocha/Merge.js
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,8 @@ describe('Merge component', () => {
];
const received = [];
out.on('connect', () => received.push('CONN'));
out.on('begingroup', group => received.push(`< ${group}`));
out.on('data', data => received.push(`DATA ${data}`));
out.on('begingroup', (group) => received.push(`< ${group}`));
out.on('data', (data) => received.push(`DATA ${data}`));
out.on('endgroup', () => received.push('>'));
out.on('disconnect', () => {
received.push('DISC');
Expand Down
4 changes: 2 additions & 2 deletions spec/mocha/Output.js
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,8 @@ describe('Output component', () => {
];
const received = [];
out.on('connect', () => received.push('CONN'));
out.on('begingroup', group => received.push(`< ${group}`));
out.on('data', data => received.push(`DATA ${data}`));
out.on('begingroup', (group) => received.push(`< ${group}`));
out.on('data', (data) => received.push(`DATA ${data}`));
out.on('endgroup', () => received.push('>'));
out.on('disconnect', () => {
received.push('DISC');
Expand Down
4 changes: 2 additions & 2 deletions spec/mocha/RepeatAsync.js
Original file line number Diff line number Diff line change
Expand Up @@ -45,8 +45,8 @@ describe('RepeatAsync component', () => {
];
const received = [];
out.on('connect', () => received.push('CONN'));
out.on('begingroup', group => received.push(`< ${group}`));
out.on('data', data => received.push(`DATA ${data}`));
out.on('begingroup', (group) => received.push(`< ${group}`));
out.on('data', (data) => received.push(`DATA ${data}`));
out.on('endgroup', () => received.push('>'));
out.on('disconnect', () => {
received.push('DISC');
Expand Down
4 changes: 2 additions & 2 deletions spec/mocha/SendNext.js
Original file line number Diff line number Diff line change
Expand Up @@ -59,8 +59,8 @@ describe('SendNext component', () => {
];

out.on('connect', () => received.push('CONN'));
out.on('begingroup', group => received.push(`< ${group}`));
out.on('data', d => received.push(`DATA ${d}`));
out.on('begingroup', (group) => received.push(`< ${group}`));
out.on('data', (d) => received.push(`DATA ${d}`));
out.on('endgroup', () => received.push('>'));
out.on('disconnect', () => received.push('DISC'));

Expand Down
10 changes: 5 additions & 5 deletions spec/mocha/Split.js
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ describe('Split component', () => {
});
it('should forward groups', (done) => {
const groups = [];
out.on('begingroup', group => groups.push(group));
out.on('begingroup', (group) => groups.push(group));
out.on('endgroup', () => groups.pop());
out.on('data', (data) => {
chai.expect(data).to.equal('foo');
Expand Down Expand Up @@ -85,7 +85,7 @@ describe('Split component', () => {
const ids = ['foo', 'bar', 'baz'];
let packets = [];
const groups = [];
out.on('begingroup', group => groups.push(group));
out.on('begingroup', (group) => groups.push(group));
out.on('endgroup', () => groups.pop());
out.on('data', (data) => {
packets.push({
Expand All @@ -95,10 +95,10 @@ describe('Split component', () => {
if (packets.length > 2) {
chai.expect(packets.length).to.deep.equal(3);
ids.forEach((id) => {
const allData = packets.map(p => p.data);
const allData = packets.map((p) => p.data);
const idGroups = packets
.filter(p => p.data === id)
.map(p => p.groups);
.filter((p) => p.data === id)
.map((p) => p.groups);
chai.expect(allData).to.include(id);
chai.expect(idGroups[0]).to.deep.equal([`group-of-${id}`]);
});
Expand Down

0 comments on commit 4236a2f

Please sign in to comment.