| 287 | } |
| 288 | |
| 289 | bool redis_stream::xread(redis_stream_messages& messages, |
| 290 | const std::map<string, string>& streams, |
| 291 | size_t count /* = 1000 */, ssize_t block /* = 0 */) |
| 292 | { |
| 293 | if (streams.size() == 1) { |
| 294 | std::map<string, string>::const_iterator cit = streams.begin(); |
| 295 | hash_slot(cit->first); |
| 296 | } |
| 297 | xread_build(streams, count, block); |
| 298 | return get_results(messages); |
| 299 | } |
| 300 | |
| 301 | bool redis_stream::xreadgroup(redis_stream_messages& messages, |
| 302 | const char* group, const char* consumer, |
no test coverage detected