diff --git a/packages/client/lib/client/index.ts b/packages/client/lib/client/index.ts index 85dfd9f5e9..2b256e41e0 100644 --- a/packages/client/lib/client/index.ts +++ b/packages/client/lib/client/index.ts @@ -857,11 +857,11 @@ export default class RedisClient< const maybeClose = () => { if (!this._queue.isEmpty()) return; - this._socket.removeEventListener('data', maybeClose); + this._socket.off('data', maybeClose); this._socket.destroySocket(); resolve(); }; - this._socket.addEventListener('data', maybeClose); + this._socket.on('data', maybeClose); }); }