From 49d855d357d6b85fd7cc53d72ed5b9cd8b5fd06d Mon Sep 17 00:00:00 2001 From: Marko Vejnovic Date: Tue, 4 Nov 2025 14:53:33 -0800 Subject: [PATCH] before claude --- test/js/valkey2/valkey.test.ts | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/test/js/valkey2/valkey.test.ts b/test/js/valkey2/valkey.test.ts index b57f10012b..fadbc9a2d8 100644 --- a/test/js/valkey2/valkey.test.ts +++ b/test/js/valkey2/valkey.test.ts @@ -6645,11 +6645,11 @@ describeValkey( await client.unsubscribe(channel); }); - test("subscribing to a channel receives messages", async () => { + test.each(ValkeyFaker.channels(randomEngine, 4))("loopback on %s channel", async (testChannel: string) => { const TEST_MESSAGE_COUNT = 128; const subscriber = await ctx.connectedClient(); - const testChannel = "message-receive-test"; - const testMessage = "hello world"; + + const testMessage = ValkeyFaker.publishMessage(randomEngine); const counter = new promises.AwaitableCounter(); await subscriber.subscribe(testChannel, (message: string, channel: string) => { @@ -6663,7 +6663,6 @@ describeValkey( }); await counter.untilValue(TEST_MESSAGE_COUNT); - await subscriber.unsubscribe(testChannel); }); });