|
7 | 7 | #ifndef BOOST_REDIS_CONNECTION_HPP
|
8 | 8 | #define BOOST_REDIS_CONNECTION_HPP
|
9 | 9 |
|
10 |
| -#include "boost/redis/request.hpp" |
11 | 10 | #include <boost/redis/adapter/any_adapter.hpp>
|
12 | 11 | #include <boost/redis/detail/connection_base.hpp>
|
13 | 12 | #include <boost/redis/logger.hpp>
|
|
19 | 18 | #include <boost/asio/any_completion_handler.hpp>
|
20 | 19 |
|
21 | 20 | #include <chrono>
|
| 21 | +#include <cstddef> |
22 | 22 | #include <limits>
|
23 | 23 |
|
24 | 24 | namespace boost::redis {
|
@@ -414,7 +414,7 @@ class connection {
|
414 | 414 | {
|
415 | 415 | return asio::async_initiate<
|
416 | 416 | CompletionToken, void(boost::system::error_code)>(
|
417 |
| - [](auto handler, connection* self, request const* req, any_adapter adapter) |
| 417 | + [](auto handler, connection* self, request const* req, any_adapter&& adapter) |
418 | 418 | {
|
419 | 419 | self->async_exec_impl(*req, std::move(adapter), std::move(handler));
|
420 | 420 | }, token, this, &req, std::move(adapter));
|
@@ -462,8 +462,8 @@ class connection {
|
462 | 462 | void
|
463 | 463 | async_exec_impl(
|
464 | 464 | request const& req,
|
465 |
| - any_adapter adapter, |
466 |
| - asio::any_completion_handler<void(boost::system::error_code)> token); |
| 465 | + any_adapter&& adapter, |
| 466 | + asio::any_completion_handler<void(boost::system::error_code, std::size_t)> token); |
467 | 467 |
|
468 | 468 | basic_connection<executor_type> impl_;
|
469 | 469 | };
|
|
0 commit comments