mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-12 03:48:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

before claude

Browse Source
This commit is contained in:
Marko Vejnovic
2025-11-04 14:53:33 -08:00
parent cd2b0b3496
commit 49d855d357
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
test/js/valkey2/valkey.test.ts
View File

@@ -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);
});
});