diff options
Diffstat (limited to 'src/blocked.c')
| -rw-r--r-- | src/blocked.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/blocked.c b/src/blocked.c index 00cc798d5..d1e718158 100644 --- a/src/blocked.c +++ b/src/blocked.c @@ -395,7 +395,7 @@ void serveClientsBlockedOnStreamKey(robj *o, readyList *rl) { }; streamReplyWithRange(receiver,s,&start,NULL, receiver->bpop.xread_count, - 0, group, consumer, noack, &pi); + 0, group, consumer, noack, &pi, 1); /* Note that after we unblock the client, 'gt' * and other receiver->bpop stuff are no longer |