| 299 | } |
| 300 | |
| 301 | bool redis_stream::xreadgroup(redis_stream_messages& messages, |
| 302 | const char* group, const char* consumer, |
| 303 | const std::map<string, string>& streams, size_t count /* = 1000 */, |
| 304 | ssize_t block /* = 0 */, bool noack /* = false */) |
| 305 | { |
| 306 | if (streams.size() == 1) { |
| 307 | std::map<string, string>::const_iterator cit = streams.begin(); |
| 308 | hash_slot(cit->first); |
| 309 | } |
| 310 | xreadgroup_build(group, consumer, streams, count, block, noack); |
| 311 | return get_results(messages); |
| 312 | } |
| 313 | |
| 314 | |
| 315 | bool redis_stream::xreadgroup_with_noack(redis_stream_messages& messages, |
no test coverage detected