Skip to content

Commit a79bb3c

Browse files
committed
Rebase fixes.
1 parent 98fce5e commit a79bb3c

File tree

5 files changed

+8
-8
lines changed

5 files changed

+8
-8
lines changed

include/boost/redis/adapter/detail/adapters.hpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ class general_aggregate<result<flat_response_value>> {
195195
}
196196

197197
template <class String>
198-
void operator()(resp3::basic_node<String> const& nd, system::error_code&)
198+
void on_node(resp3::basic_node<String> const& nd, system::error_code&)
199199
{
200200
BOOST_ASSERT_MSG(!!result_, "Unexpected null pointer");
201201
switch (nd.data_type) {

include/boost/redis/adapter/detail/response_traits.hpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,9 +110,9 @@ struct response_traits<response<Ts...>> {
110110
template <>
111111
struct response_traits<generic_flat_response> {
112112
using response_type = generic_flat_response;
113-
using adapter_type = vector_adapter<response_type>;
113+
using adapter_type = general_aggregate<response_type>;
114114

115-
static auto adapt(response_type& v) noexcept { return adapter_type{v}; }
115+
static auto adapt(response_type& v) noexcept { return adapter_type{&v}; }
116116
};
117117
} // namespace boost::redis::adapter::detail
118118

test/test_conn_exec_cancel.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ using boost::redis::operation;
3232
using boost::redis::error;
3333
using boost::redis::request;
3434
using boost::redis::response;
35-
using boost::redis::generic_flat_response;
35+
using boost::redis::generic_response;
3636
using boost::redis::ignore;
3737
using boost::redis::ignore_t;
3838
using boost::redis::logger;

test/test_conn_exec_error.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ using error_code = boost::system::error_code;
2121
using boost::redis::connection;
2222
using boost::redis::request;
2323
using boost::redis::response;
24-
using boost::redis::generic_flat_response;
24+
using boost::redis::generic_response;
2525
using boost::redis::ignore;
2626
using boost::redis::ignore_t;
2727
using boost::redis::error;
@@ -266,7 +266,7 @@ BOOST_AUTO_TEST_CASE(subscriber_wrong_syntax)
266266

267267
conn->async_exec(req1, ignore, c1);
268268

269-
generic_flat_response gresp;
269+
generic_response gresp;
270270
conn->set_receive_response(gresp);
271271

272272
auto c3 = [&](error_code ec, std::size_t) {
@@ -326,4 +326,4 @@ BOOST_AUTO_TEST_CASE(issue_287_generic_response_error_then_success)
326326
BOOST_TEST(resp.error().diagnostic == "ERR wrong number of arguments for 'set' command");
327327
}
328328

329-
} // namespace
329+
} // namespace

test/test_reader_fsm.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ void test_read_error()
167167
void test_parse_error()
168168
{
169169
multiplexer mpx;
170-
generic_flat_response resp;
170+
generic_response resp;
171171
mpx.set_receive_adapter(any_adapter{resp});
172172
reader_fsm fsm{mpx};
173173
error_code ec;

0 commit comments

Comments
 (0)