Skip to content

Commit 9b5270d

Browse files
committed
fix: test
1 parent a7bd4ad commit 9b5270d

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

test/ClusteredRedisQueue.addServer.defaultInit.spec.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ describe('ClusteredRedisQueue.addServerWithQueueInitializing() default param', (
2727

2828
// Ensure the server added and queue length updated
2929
expect((cq as any).servers.some((s: any) => s.host === server.host && s.port === server.port)).to.equal(true);
30-
expect((cq as any).queueLength).to.equal((cq as any).imqs.length);
30+
expect((cq as any).imqLength).to.equal((cq as any).imqs.length);
3131

3232
await cq.destroy();
3333
});

test/ClusteredRedisQueue.addServer.noInit.spec.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ describe('ClusteredRedisQueue.addServerWithQueueInitializing(false)', () => {
2323
expect(cq.servers.length).to.be.greaterThan(0);
2424
expect(cq.imqs.length).to.be.greaterThan(0);
2525
// queueLength updated
26-
expect(cq.queueLength).to.equal(cq.imqs.length);
26+
expect(cq.imqLength).to.equal(cq.imqs.length);
2727
// initialized not emitted
2828
expect(initializedCalled).to.equal(false);
2929

0 commit comments

Comments
 (0)