Skip to content

Commit 0b1f727

Browse files
author
Weyoss
committed
fix(redis-smq): await async queue consumers retrieval in test
1 parent cf8415d commit 0b1f727

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

packages/redis-smq/tests/tests/consuming-messages/test00032.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ test('Consume message from different queues using a single consumer instance: ca
4343
const a = await _getConsumerQueuesAsync(redisClient, consumer.getId());
4444
expect(a).toEqual([]);
4545

46-
const a1 = _getQueueConsumersAsync(redisClient, defaultQueue);
46+
const a1 = await _getQueueConsumersAsync(redisClient, defaultQueue);
4747
expect(Object.keys(a1)).toEqual([]);
4848

4949
await consumer.consumeAsync(

0 commit comments

Comments
 (0)