diff --git a/packages/client/lib/client/pool.spec.ts b/packages/client/lib/client/pool.spec.ts index f292dc171c7..83572bcf07d 100644 --- a/packages/client/lib/client/pool.spec.ts +++ b/packages/client/lib/client/pool.spec.ts @@ -9,6 +9,11 @@ describe('RedisClientPool', () => { ); }, GLOBAL.SERVERS.OPEN); + testUtils.testWithClientPool('close', async pool => { + await pool.close() + assert.equal(pool.totalClients, 0) + }, GLOBAL.SERVERS.OPEN); + testUtils.testWithClientPool( 'proper error propagation in sequential operations', async (pool) => { diff --git a/packages/client/lib/client/pool.ts b/packages/client/lib/client/pool.ts index 75aca57a9f5..08dd3b04910 100644 --- a/packages/client/lib/client/pool.ts +++ b/packages/client/lib/client/pool.ts @@ -518,7 +518,7 @@ export class RedisClientPool< await Promise.all(promises); - this.#clientSideCache?.onPoolClose(); + this._self.#clientSideCache?.onPoolClose(); this._self.#idleClients.reset(); this._self.#clientsInUse.reset();