mirror of
https://github.com/vdemydiuk/mtapi.git
synced 2026-07-28 11:07:48 +00:00
40 lines
854 B
C++
40 lines
854 B
C++
|
/* Copyright (c) 2018-2023 Marcelo Zimbres Silva (mzimbres@gmail.com)
|
||
|
|
*
|
||
|
|
* Distributed under the Boost Software License, Version 1.0. (See
|
||
|
|
* accompanying file LICENSE.txt)
|
||
|
|
*/
|
||
|
|
|
||
|
|
#include <boost/redis/connection.hpp>
|
||
|
|
|
||
|
|
namespace boost::redis {
|
||
|
|
|
||
|
|
connection::connection(
|
||
|
|
executor_type ex,
|
||
|
|
asio::ssl::context::method method,
|
||
|
|
std::size_t max_read_size)
|
||
|
|
: impl_{ex, method, max_read_size}
|
||
|
|
{ }
|
||
|
|
|
||
|
|
connection::connection(
|
||
|
|
asio::io_context& ioc,
|
||
|
|
asio::ssl::context::method method,
|
||
|
|
std::size_t max_read_size)
|
||
|
|
: impl_{ioc.get_executor(), method, max_read_size}
|
||
|
|
{ }
|
||
|
|
|
||
|
|
void
|
||
|
|
connection::async_run_impl(
|
||
|
|
config const& cfg,
|
||
|
|
logger l,
|
||
|
|
asio::any_completion_handler<void(boost::system::error_code)> token)
|
||
|
|
{
|
||
|
|
impl_.async_run(cfg, l, std::move(token));
|
||
|
|
}
|
||
|
|
|
||
|
|
void connection::cancel(operation op)
|
||
|
|
{
|
||
|
|
impl_.cancel(op);
|
||
|
|
}
|
||
|
|
|
||
|
|
} // namespace boost::redis
|