Consider sub by pattern when clear subscribed flag

1 files changed, 3 insertions, 1 deletions

diff --git a/async.c b/async.c
index 3654580..e3f5ac3 100644
--- a/async.c
+++ b/async.c
@@ -407,7 +407,9 @@ static int __redisGetSubscribeCallback(redisAsyncContext *ac, redisReply *reply,
                 assert(reply->element[2]->type == REDIS_REPLY_INTEGER);
 
                 /* Unset subscribed flag only when no pipelined pending subscribe. */
-                if (reply->element[2]->integer == 0 && dictSize(callbacks) == 0)
+                if (reply->element[2]->integer == 0 
+                    && dictSize(ac->sub.channels) == 0
+                    && dictSize(ac->sub.patterns) == 0)
                     c->flags &= ~REDIS_SUBSCRIBED;
             }
         }