diff --git a/lib_acl_cpp/src/redis/redis_stream.cpp b/lib_acl_cpp/src/redis/redis_stream.cpp index de0108b46a2a965c85afe1da2639b68b7f276e54..d971678de20fae08b2f3d6e1128f7f9c7f906f9e 100644 --- a/lib_acl_cpp/src/redis/redis_stream.cpp +++ b/lib_acl_cpp/src/redis/redis_stream.cpp @@ -222,17 +222,18 @@ void redis_stream::build(const std::map& streams, size_t i, argv_lens_[i] = sizeof("STREAMS") - 1; i++; + size_t streams_n = streams.size(); for (std::map::const_iterator cit = streams.begin(); cit != streams.end(); ++cit) { argv_[i] = cit->first.c_str(); argv_lens_[i] = cit->first.size(); - i++; - argv_[i] = cit->second.c_str(); - argv_lens_[i] = cit->second.size(); + argv_[i+streams_n] = cit->second.c_str(); + argv_lens_[i+streams_n] = cit->second.size(); i++; } + i+=streams_n; build_request(i, argv_, argv_lens_); }