Searched refs:xreadgroup (Results 1 – 5 of 5) sorted by relevance
104 set c [llength [lindex [r xreadgroup group g1 c1 streams events >] 0 1]]107 set c [llength [lindex [r xreadgroup group g1 c2 streams events >] 0 1]]123 set res [r xreadgroup group mygroup myconsumer count 3 streams events 0]127 set res [r xreadgroup group mygroup myconsumer count 3 streams events >]131 set res [r xreadgroup group mygroup myconsumer count 3 streams events 0]265 set item [$master xreadgroup group mygroup \268 set item [$master xreadgroup group mygroup \282 set item [$slave xreadgroup group mygroup myconsumer \
52 r xreadgroup GROUP mygroup Alice COUNT 1 STREAMS stream >
110 r xreadgroup GROUP mygroup Alice COUNT 1 STREAMS stream >
1338 int xreadgroup = sdslen(c->argv[0]->ptr) == 10; /* XREAD or XREADGROUP? */ in xreadCommand() local1367 if (!xreadgroup) { in xreadCommand()1376 if (!xreadgroup) { in xreadCommand()1396 if (xreadgroup && groupname == NULL) { in xreadCommand()1432 if (xreadgroup) { in xreadCommand()1449 if (!xreadgroup) { in xreadCommand()
2143 Streams: return an error message if using xreadgroup with '$' ID.2295 Merge pull request #5112 from 0xtonyxia/fix-xreadgroup-crash-after-setid2331 Streams: fix xreadgroup crash after xgroup SETID is sent.2337 Bugfix: PEL is incorrect when consumer is blocked using xreadgroup with NOACK option.