Skip to content

Commit 1abc23f

Browse files
fix(ioredis): call connect() when lazyConnect is true
1 parent f0152ca commit 1abc23f

2 files changed

Lines changed: 18 additions & 3 deletions

File tree

lib/util.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ export async function duplicateClient(redisClient: any) {
4747
// ignore errors
4848
});
4949

50-
if (isRedisV4Client(redisClient)) {
50+
if (isRedisV4Client(redisClient) || redisClient.options.lazyConnect) {
5151
await newClient.connect();
5252
}
5353
return newClient;

test/test-runner.ts

Lines changed: 17 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,8 +89,23 @@ describe("@socket.io/redis-streams-adapter", () => {
8989
});
9090

9191
describe("ioredis with single Redis node", () => {
92-
testSuites(() => {
93-
return new Redis();
92+
describe("default options", () => {
93+
testSuites(() => {
94+
return new Redis();
95+
});
96+
});
97+
98+
describe("with lazyConnect: true and enableOfflineQueue: false", () => {
99+
testSuites(async () => {
100+
const redis = new Redis({
101+
lazyConnect: true,
102+
enableOfflineQueue: false,
103+
});
104+
105+
await redis.connect();
106+
107+
return redis;
108+
});
94109
});
95110
});
96111

0 commit comments

Comments
 (0)