From 37a1ced50145851d3c3c7e1792df1120794c904f Mon Sep 17 00:00:00 2001
From: yedemon <yedemon@163.com>
Date: Tue, 29 Mar 2022 14:49:28 +0800
Subject: [PATCH] Add wg.wait for redisq

wg in redisq/queue.go has no wait method called. Studied and imitated from other queue implementations.
---
 redisq/queue.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/redisq/queue.go b/redisq/queue.go
index 7568e34..d6aed46 100644
--- a/redisq/queue.go
+++ b/redisq/queue.go
@@ -280,6 +280,9 @@ func (q *Queue) CloseTimeout(timeout time.Duration) error {
 	_ = q.redis.XGroupDelConsumer(
 		context.TODO(), q.stream, q.streamGroup, q.streamConsumer).Err()
 
+	// maybe place the wg.wait for redisq here?
+	q.wg.Wait()
+	
 	return nil
 }