diff --git a/lib/autoPipelining.ts b/lib/autoPipelining.ts index 410507f..68adc2a 100644 --- a/lib/autoPipelining.ts +++ b/lib/autoPipelining.ts @@ -17,6 +17,7 @@ export const notAllowedAutoPipelineCommands = [ "psubscribe", "unsubscribe", "unpsubscribe", + "select", ]; function executeAutoPipeline(client, slotKey: string) { diff --git a/test/functional/autopipelining.ts b/test/functional/autopipelining.ts index c221316..cfc62b1 100644 --- a/test/functional/autopipelining.ts +++ b/test/functional/autopipelining.ts @@ -31,6 +31,16 @@ describe("autoPipelining for single node", () => { await promises; }); + it("should work with db parameter", async () => { + const redis = new Redis({ enableAutoPipelining: true, db: 1 }); + + redis.set("foo", "bar"); + await new Promise((resolve) => { + redis.once("ready", resolve); + }); + expect(await redis.get("foo")).to.eql("bar"); + }); + it("should not add blacklisted commands to auto pipelines", async () => { const redis = new Redis({ enableAutoPipelining: true,