Skip to content

Commit

Permalink
fixup
Browse files Browse the repository at this point in the history
  • Loading branch information
benzekrimaha committed Nov 12, 2024
1 parent 1aa3a0e commit d626f3b
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions tests/unit/lib/queuePopulator/KafkaLogReader.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,8 @@ describe('KafkaLogReader', () => {
});

it('should handle log consumer setup error', done => {
const setupStub = sinon.stub(kafkaLogReader.logConsumer, 'setup').callsFake(callback => callback(new Error('setup error')));
const setupStub = sinon.stub(kafkaLogReader.logConsumer, 'setup')
.callsFake(callback => callback(new Error('setup error')));
kafkaLogReader.setup(err => {
assert.strictEqual(err.message, 'setup error');
assert(setupStub.calledOnce);
Expand All @@ -89,4 +90,4 @@ describe('KafkaLogReader', () => {
});
});
});
});
});

0 comments on commit d626f3b

Please sign in to comment.