remove max count for xread

This commit is contained in:
Grant Limberg 2022-04-28 13:10:07 -07:00
parent 1c700b7b41
commit 59151fbf86
No known key found for this signature in database
GPG Key ID: 8F2F97D3BE8D7735

View File

@ -944,9 +944,9 @@ void PostgreSQL::_membersWatcher_Redis() {
json tmp;
std::unordered_map<std::string, ItemStream> result;
if (_rc->clusterMode) {
_cluster->xread(key, lastID, std::chrono::seconds(1), 10, std::inserter(result, result.end()));
_cluster->xread(key, lastID, std::chrono::seconds(1), 0, std::inserter(result, result.end()));
} else {
_redis->xread(key, lastID, std::chrono::seconds(1), 10, std::inserter(result, result.end()));
_redis->xread(key, lastID, std::chrono::seconds(1), 0, std::inserter(result, result.end()));
}
if (!result.empty()) {
for (auto element : result) {