test(publisher): increase sleep duration to ensure proper auto-unsubscription in Redis and Upstash tests

Author: dinwwwh

packages/bun/src/redis-publisher.test.ts

@@ -313,8 +313,9 @@ describe.skipIf(!REDIS_URL)('bun redis publisher', () => {
       onError,
     })).rejects.toThrow()
 
+    await sleep(1000) // ensure auto-unsubscribed
     await publisher.publish(event, { order: 1 })
-    await sleep(300)
+    await sleep(1000)
 
     expect(onError).not.toHaveBeenCalled()
     expect(listener).not.toHaveBeenCalled()

packages/publisher/src/adapters/redis.test.ts

@@ -315,8 +315,9 @@ describe.concurrent('redisPublisher', { skip: !REDIS_URL, timeout: 20_000 }, ()
       onError,
     })).rejects.toThrow()
 
+    await sleep(1000) // ensure auto-unsubscribed
     await publisher.publish(event, { order: 1 })
-    await sleep(300)
+    await sleep(1000)
 
     expect(onError).not.toHaveBeenCalled()
     expect(listener).not.toHaveBeenCalled()

packages/publisher/src/adapters/upstash.test.ts

@@ -367,8 +367,8 @@ describe.concurrent(
         onError,
       })).rejects.toThrow()
 
+      await sleep(1000) // ensure auto-unsubscribed
       await publisher.publish(event, { order: 1 })
-
       await sleep(1000)
 
       expect(onError).toHaveBeenCalledTimes(0)