amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 15:08:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: fix outdated test

Browse Source
This commit is contained in:
Kamil Myśliwiec
2026-02-15 16:52:29 +01:00
parent 70323a132a
commit 43c0eb67c1
1 changed files with 17 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
packages/microservices/test/server/server-kafka.spec.ts
View File

@@ -258,11 +258,13 @@ describe('ServerKafka', () => {
await server.listen(callback);
await server.bindEvents(untypedServer.consumer);
expect(run.called).to.be.true;
expect(run.firstCall.args[0]).to.include({
partitionsConsumedConcurrently: 5,
});
expect(run.firstCall.args[0]).to.have.property('eachMessage');
expect(run).toHaveBeenCalled();
expect(run.mock.calls[0][0]).toEqual(
expect.objectContaining({
partitionsConsumedConcurrently: 5,
}),
);
expect(run.mock.calls[0][0]).toHaveProperty('eachMessage');
});
it('should pass multiple run options to consumer.run()', async () => {
untypedServer.logger = new NoopLogger();
@@ -274,14 +276,16 @@ describe('ServerKafka', () => {
await server.listen(callback);
await server.bindEvents(untypedServer.consumer);
expect(run.called).to.be.true;
const callArg = run.firstCall.args[0];
expect(callArg).to.include({
partitionsConsumedConcurrently: 3,
autoCommit: false,
autoCommitInterval: 5000,
});
expect(callArg).to.have.property('eachMessage');
expect(run).toHaveBeenCalled();
const callArg = run.mock.calls[0][0];
expect(callArg).toEqual(
expect.objectContaining({
partitionsConsumedConcurrently: 3,
autoCommit: false,
autoCommitInterval: 5000,
}),
);
expect(callArg).toHaveProperty('eachMessage');
});
});