123456789101112131415161718192021222324252627282930313233343536373839 |
- #include <boost/redis/connection.hpp>
- namespace boost::redis {
- connection::connection(
- executor_type ex,
- asio::ssl::context ctx,
- std::size_t max_read_size)
- : impl_{ex, std::move(ctx), max_read_size}
- { }
- connection::connection(
- asio::io_context& ioc,
- asio::ssl::context ctx,
- std::size_t max_read_size)
- : impl_{ioc.get_executor(), std::move(ctx), 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);
- }
- }
|