mirror of
https://github.com/boostorg/redis.git
synced 2026-01-19 04:42:09 +00:00
committed by
GitHub
parent
02632b31c6
commit
2bbf0090b5
@@ -9,9 +9,13 @@
|
||||
|
||||
#include <boost/assert.hpp>
|
||||
|
||||
#include <algorithm>
|
||||
|
||||
namespace boost::redis {
|
||||
|
||||
void consume_one(generic_response& r, system::error_code& ec)
|
||||
namespace detail {
|
||||
|
||||
inline void consume_one_impl(generic_response& r, system::error_code& ec)
|
||||
{
|
||||
if (r.has_error())
|
||||
return; // Nothing to consume.
|
||||
@@ -38,10 +42,14 @@ void consume_one(generic_response& r, system::error_code& ec)
|
||||
r.value().erase(std::cbegin(r.value()), match);
|
||||
}
|
||||
|
||||
} // namespace detail
|
||||
|
||||
void consume_one(generic_response& r, system::error_code& ec) { detail::consume_one_impl(r, ec); }
|
||||
|
||||
void consume_one(generic_response& r)
|
||||
{
|
||||
system::error_code ec;
|
||||
consume_one(r, ec);
|
||||
detail::consume_one_impl(r, ec);
|
||||
if (ec)
|
||||
throw system::system_error(ec);
|
||||
}
|
||||
|
||||
@@ -8,15 +8,13 @@
|
||||
#define BOOST_REDIS_RESPONSE_HPP
|
||||
|
||||
#include <boost/redis/adapter/result.hpp>
|
||||
#include <boost/redis/resp3/flat_tree.hpp>
|
||||
#include <boost/redis/resp3/node.hpp>
|
||||
#include <boost/redis/resp3/tree.hpp>
|
||||
#include <boost/redis/resp3/flat_tree.hpp>
|
||||
|
||||
#include <boost/system/error_code.hpp>
|
||||
|
||||
#include <string>
|
||||
#include <tuple>
|
||||
#include <vector>
|
||||
|
||||
namespace boost::redis {
|
||||
|
||||
@@ -75,7 +73,7 @@ using generic_flat_response = adapter::result<resp3::flat_tree>;
|
||||
* @param r The response to modify.
|
||||
* @param ec Will be populated in case of error.
|
||||
*/
|
||||
//BOOST_DEPRECATED("This function is not needed anymore to consume server pushes.")
|
||||
BOOST_DEPRECATED("This function is not needed anymore to consume server pushes.")
|
||||
void consume_one(generic_response& r, system::error_code& ec);
|
||||
|
||||
/**
|
||||
@@ -83,7 +81,7 @@ void consume_one(generic_response& r, system::error_code& ec);
|
||||
*
|
||||
* @param r The response to modify.
|
||||
*/
|
||||
//BOOST_DEPRECATED("This function is not needed anymore to consume server pushes.")
|
||||
BOOST_DEPRECATED("This function is not needed anymore to consume server pushes.")
|
||||
void consume_one(generic_response& r);
|
||||
|
||||
} // namespace boost::redis
|
||||
|
||||
Reference in New Issue
Block a user