123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269 |
- //
- // this_coro.hpp
- // ~~~~~~~~~~~~~
- //
- // 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)
- //
- #ifndef BOOST_ASIO_THIS_CORO_HPP
- #define BOOST_ASIO_THIS_CORO_HPP
- #if defined(_MSC_VER) && (_MSC_VER >= 1200)
- # pragma once
- #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
- #include <boost/asio/detail/config.hpp>
- #include <boost/asio/detail/type_traits.hpp>
- #include <boost/asio/detail/push_options.hpp>
- namespace boost {
- namespace asio {
- namespace this_coro {
- /// Awaitable type that returns the executor of the current coroutine.
- struct executor_t
- {
- constexpr executor_t()
- {
- }
- };
- /// Awaitable object that returns the executor of the current coroutine.
- constexpr executor_t executor;
- /// Awaitable type that returns the cancellation state of the current coroutine.
- struct cancellation_state_t
- {
- constexpr cancellation_state_t()
- {
- }
- };
- /// Awaitable object that returns the cancellation state of the current
- /// coroutine.
- /**
- * @par Example
- * @code boost::asio::awaitable<void> my_coroutine()
- * {
- * boost::asio::cancellation_state cs
- * = co_await boost::asio::this_coro::cancellation_state;
- *
- * // ...
- *
- * if (cs.cancelled() != boost::asio::cancellation_type::none)
- * // ...
- * } @endcode
- */
- constexpr cancellation_state_t cancellation_state;
- #if defined(GENERATING_DOCUMENTATION)
- /// Returns an awaitable object that may be used to reset the cancellation state
- /// of the current coroutine.
- /**
- * Let <tt>P</tt> be the cancellation slot associated with the current
- * coroutine's @ref co_spawn completion handler. Assigns a new
- * boost::asio::cancellation_state object <tt>S</tt>, constructed as
- * <tt>S(P)</tt>, into the current coroutine's cancellation state object.
- *
- * @par Example
- * @code boost::asio::awaitable<void> my_coroutine()
- * {
- * co_await boost::asio::this_coro::reset_cancellation_state();
- *
- * // ...
- * } @endcode
- *
- * @note The cancellation state is shared by all coroutines in the same "thread
- * of execution" that was created using boost::asio::co_spawn.
- */
- BOOST_ASIO_NODISCARD constexpr unspecified
- reset_cancellation_state();
- /// Returns an awaitable object that may be used to reset the cancellation state
- /// of the current coroutine.
- /**
- * Let <tt>P</tt> be the cancellation slot associated with the current
- * coroutine's @ref co_spawn completion handler. Assigns a new
- * boost::asio::cancellation_state object <tt>S</tt>, constructed as <tt>S(P,
- * std::forward<Filter>(filter))</tt>, into the current coroutine's
- * cancellation state object.
- *
- * @par Example
- * @code boost::asio::awaitable<void> my_coroutine()
- * {
- * co_await boost::asio::this_coro::reset_cancellation_state(
- * boost::asio::enable_partial_cancellation());
- *
- * // ...
- * } @endcode
- *
- * @note The cancellation state is shared by all coroutines in the same "thread
- * of execution" that was created using boost::asio::co_spawn.
- */
- template <typename Filter>
- BOOST_ASIO_NODISCARD constexpr unspecified
- reset_cancellation_state(Filter&& filter);
- /// Returns an awaitable object that may be used to reset the cancellation state
- /// of the current coroutine.
- /**
- * Let <tt>P</tt> be the cancellation slot associated with the current
- * coroutine's @ref co_spawn completion handler. Assigns a new
- * boost::asio::cancellation_state object <tt>S</tt>, constructed as <tt>S(P,
- * std::forward<InFilter>(in_filter),
- * std::forward<OutFilter>(out_filter))</tt>, into the current coroutine's
- * cancellation state object.
- *
- * @par Example
- * @code boost::asio::awaitable<void> my_coroutine()
- * {
- * co_await boost::asio::this_coro::reset_cancellation_state(
- * boost::asio::enable_partial_cancellation(),
- * boost::asio::disable_cancellation());
- *
- * // ...
- * } @endcode
- *
- * @note The cancellation state is shared by all coroutines in the same "thread
- * of execution" that was created using boost::asio::co_spawn.
- */
- template <typename InFilter, typename OutFilter>
- BOOST_ASIO_NODISCARD constexpr unspecified
- reset_cancellation_state(
- InFilter&& in_filter,
- OutFilter&& out_filter);
- /// Returns an awaitable object that may be used to determine whether the
- /// coroutine throws if trying to suspend when it has been cancelled.
- /**
- * @par Example
- * @code boost::asio::awaitable<void> my_coroutine()
- * {
- * if (co_await boost::asio::this_coro::throw_if_cancelled)
- * // ...
- *
- * // ...
- * } @endcode
- */
- BOOST_ASIO_NODISCARD constexpr unspecified
- throw_if_cancelled();
- /// Returns an awaitable object that may be used to specify whether the
- /// coroutine throws if trying to suspend when it has been cancelled.
- /**
- * @par Example
- * @code boost::asio::awaitable<void> my_coroutine()
- * {
- * co_await boost::asio::this_coro::throw_if_cancelled(false);
- *
- * // ...
- * } @endcode
- */
- BOOST_ASIO_NODISCARD constexpr unspecified
- throw_if_cancelled(bool value);
- #else // defined(GENERATING_DOCUMENTATION)
- struct reset_cancellation_state_0_t
- {
- constexpr reset_cancellation_state_0_t()
- {
- }
- };
- BOOST_ASIO_NODISCARD inline constexpr reset_cancellation_state_0_t
- reset_cancellation_state()
- {
- return reset_cancellation_state_0_t();
- }
- template <typename Filter>
- struct reset_cancellation_state_1_t
- {
- template <typename F>
- explicit constexpr reset_cancellation_state_1_t(
- F&& filt)
- : filter(static_cast<F&&>(filt))
- {
- }
- Filter filter;
- };
- template <typename Filter>
- BOOST_ASIO_NODISCARD inline constexpr reset_cancellation_state_1_t<
- decay_t<Filter>>
- reset_cancellation_state(Filter&& filter)
- {
- return reset_cancellation_state_1_t<decay_t<Filter>>(
- static_cast<Filter&&>(filter));
- }
- template <typename InFilter, typename OutFilter>
- struct reset_cancellation_state_2_t
- {
- template <typename F1, typename F2>
- constexpr reset_cancellation_state_2_t(
- F1&& in_filt, F2&& out_filt)
- : in_filter(static_cast<F1&&>(in_filt)),
- out_filter(static_cast<F2&&>(out_filt))
- {
- }
- InFilter in_filter;
- OutFilter out_filter;
- };
- template <typename InFilter, typename OutFilter>
- BOOST_ASIO_NODISCARD inline constexpr
- reset_cancellation_state_2_t<decay_t<InFilter>, decay_t<OutFilter>>
- reset_cancellation_state(InFilter&& in_filter, OutFilter&& out_filter)
- {
- return reset_cancellation_state_2_t<decay_t<InFilter>, decay_t<OutFilter>>(
- static_cast<InFilter&&>(in_filter),
- static_cast<OutFilter&&>(out_filter));
- }
- struct throw_if_cancelled_0_t
- {
- constexpr throw_if_cancelled_0_t()
- {
- }
- };
- BOOST_ASIO_NODISCARD inline constexpr throw_if_cancelled_0_t
- throw_if_cancelled()
- {
- return throw_if_cancelled_0_t();
- }
- struct throw_if_cancelled_1_t
- {
- explicit constexpr throw_if_cancelled_1_t(bool val)
- : value(val)
- {
- }
- bool value;
- };
- BOOST_ASIO_NODISCARD inline constexpr throw_if_cancelled_1_t
- throw_if_cancelled(bool value)
- {
- return throw_if_cancelled_1_t(value);
- }
- #endif // defined(GENERATING_DOCUMENTATION)
- } // namespace this_coro
- } // namespace asio
- } // namespace boost
- #include <boost/asio/detail/pop_options.hpp>
- #endif // BOOST_ASIO_THIS_CORO_HPP
|