| 313 | |
| 314 | |
| 315 | bool redis_stream::xreadgroup_with_noack(redis_stream_messages& messages, |
| 316 | const char* group, const char* consumer, |
| 317 | const std::map<string, string>& streams, size_t count /* = 0 */, |
| 318 | ssize_t block /* = 0 */) |
| 319 | { |
| 320 | return xreadgroup(messages, group, consumer, streams, count, block, true); |
| 321 | } |
| 322 | |
| 323 | bool redis_stream::xrange(redis_stream_messages& messages, const char* key, |
| 324 | const char* start, const char* end, size_t count /* = 1000 */) |
no test coverage detected