// // as_tuple.cpp // ~~~~~~~~~~~~ // // Copyright (c) 2003-2024 Christopher M. Kohlhoff (chris at kohlhoff dot com) // // Distributed under the Boost Software License, Version 1.0. (See accompanying // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) // // Disable autolinking for unit tests. #if !defined(BOOST_ALL_NO_LIB) #define BOOST_ALL_NO_LIB 1 #endif // !defined(BOOST_ALL_NO_LIB) // Test that header file is self-contained. #include "asio/as_tuple.hpp" #include "asio/bind_executor.hpp" #include "asio/deferred.hpp" #include "asio/io_context.hpp" #include "asio/post.hpp" #include "asio/system_timer.hpp" #include "asio/use_future.hpp" #include "unit_test.hpp" void as_tuple_test() { asio::io_context io1; asio::io_context io2; asio::system_timer timer1(io1); int count = 0; timer1.expires_after(asio::chrono::seconds(0)); timer1.async_wait( asio::as_tuple( asio::bind_executor(io2.get_executor(), [&count](std::tuple) { ++count; }))); ASIO_CHECK(count == 0); io1.run(); ASIO_CHECK(count == 0); io2.run(); ASIO_CHECK(count == 1); timer1.async_wait( asio::as_tuple( asio::bind_executor(io2.get_executor(), asio::deferred)))( [&count](std::tuple) { ++count; }); ASIO_CHECK(count == 1); io1.restart(); io1.run(); ASIO_CHECK(count == 1); io2.restart(); io2.run(); ASIO_CHECK(count == 2); # if defined(ASIO_HAS_STD_FUTURE_CLASS) std::future > f = timer1.async_wait( asio::as_tuple( asio::bind_executor(io2.get_executor(), asio::use_future))); ASIO_CHECK(f.wait_for(std::chrono::seconds(0)) == std::future_status::timeout); io1.restart(); io1.run(); ASIO_CHECK(f.wait_for(std::chrono::seconds(0)) == std::future_status::timeout); io2.restart(); io2.run(); ASIO_CHECK(f.wait_for(std::chrono::seconds(0)) == std::future_status::ready); # endif // defined(ASIO_HAS_STD_FUTURE_CLASS) } void as_tuple_constness_test() { # if defined(ASIO_HAS_STD_FUTURE_CLASS) asio::io_context io1; asio::system_timer timer1(io1); auto tok1 = asio::as_tuple(asio::use_future); (void)timer1.async_wait(tok1); (void)timer1.async_wait(std::move(tok1)); const auto tok2 = asio::as_tuple(asio::use_future); (void)timer1.async_wait(tok2); (void)timer1.async_wait(std::move(tok2)); constexpr auto tok3 = asio::as_tuple(asio::use_future); (void)timer1.async_wait(tok3); (void)timer1.async_wait(std::move(tok3)); # endif // defined(ASIO_HAS_STD_FUTURE_CLASS) } ASIO_TEST_SUITE ( "as_tuple", ASIO_TEST_CASE(as_tuple_test) ASIO_COMPILE_TEST_CASE(as_tuple_constness_test) )